使用 tweetstream 守护进程写入数据库

Question

我正在尝试将与关键字匹配的所有推文写入我的数据库。我在 tracker.rb 中设置了以下内容：

require 'rubygems'
require 'tweetstream'

TweetStream::Daemon.new('Bill Gates','money','Twitter Tracker').track('ladygaga') do |status|
  Tweet.new(:content => status.text)
end

但没有任何反应。我在这里做错了什么？

提前致谢

更新： 我将所有内容放入名为 twitter.rake 的 .rake 文件中，并使用 $ rake scrap 启动恶魔：

task :scrap => :environment do
  desc "Run Twitter Scraper"
  TweetStream::Client.new('TWITTER_USER','TWITTER_PASS').track('ladygaga') do |status|
    Tweet.create(:user_id  => status.user.id, :user_screen_name => status.user.screen_name, :user_profile_image_url => status.user.profile_image_url, :status_text => status.text, :status_id => status.id)
    puts "[#{status.user.screen_name}] #{status.text}"
  end
end

Answer 1

你如何调用守护进程？

您需要提供一个命令（启动/停止..）

例如：

rails runner "TweetStream::Daemon.new('tracker').track('ladygaga') { |status| do_something }" start

这将在后台启动作业

Answer 2

您的第一种方法是最好的方法，您需要从命令行运行“deamon”，但由于您想要使用rails和activerecord，因此您需要将rails环境引导到脚本中。

您需要执行以下操作：

#!/usr/bin/env ruby
# encoding: utf-8

ENV["RAILS_ENV"] ||= "development"

root  = File.expand_path(File.join(File.dirname(__FILE__), '..'))
require File.join(root, "config", "environment")

require 'tweetstream'

p "Initializing daemon..."

TweetStream.configure do |config|
  config.consumer_key       = 'your-consumer_key'
  config.consumer_secret    = 'your-consumer_secret'
  config.oauth_token        = 'your-oauth_token'
  config.oauth_token_secret = 'your-oauth_token_secret'
  config.auth_method        = :oauth
end

terms = ['ladygaga']

daemon = TweetStream::Daemon.new('tracker',
  :log_output => true,
  :backtrace  => true,
)

daemon.on_inited do
  ActiveRecord::Base.connection.reconnect!
  p "Listening..."
end

daemon.on_error do |message|
  puts "on_error: #{message}"
end

daemon.on_reconnect do |timeout, retries|
  puts "on_reconnect: #{timeout}, #{retries}"
end

daemon.on_limit do |discarded_count|
  puts "on_limit: #{skip_count}"
end

daemon.track(terms) do |status|
  # put here your model.create code!
  # Tweet.create!( :uid => status.id, ... )
end

要运行脚本，只需键入：

ruby scrip-name.rb run

Answer 3

我假设这是一个更大的 Rails 应用程序的一部分。如果是这样，问题 1 是如果 Tweet.new 是标准的 activerecord 对象，则它不会将任何内容持久保存到数据库中。尝试 Tweet.create 其次，我不确定脚本是否一定会知道推文（如果它是一个活动记录），而无需拉入 Rails 应用程序（可能通过包含environment.rb 文件）。

类似的东西：

ENV["RAILS_ENV"] ||= "production"

require File.dirname(__FILE__) + "/../../config/application"
Rails.application.require_environment!

如果这不起作用，您可以尝试仅包含活动记录，这里有一个描述它的问题和答案：

如何在 Rails 之外的 ruby​​ 脚本中使用 ActiveRecord？