使用 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 其次，我不确定脚本是否一定会知道 Tweet 如果它是一个活动记录而不拉入 rails 应用程序，可能包括 environment.rb 文件。

类似：

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

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

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

How to use ActiveRecord in a ruby script outside Rails?