Contents

class DataSiftExample
  require 'datasift'

  def initialize
    @username = 'DATASIFT_USERNAME'
    @api_key = 'DATASIFT_API_KEY'
    @config = { :username => @username, :api_key => @api_key }
    @params = {
      :output_type => 's3',
      :output_params => {
        :bucket             => 'YOUR_BUCKET_NAME',
        :directory          => 'ruby',
        :acl                => 'private',
        :delivery_frequency => 0,
        :max_size           => 104857600,
        :file_prefix        => 'DataSift',
        :auth => {
          :access_key => 'ADD_YOUR_ACCESS_KEY',
          :secret_key => 'ADD_YOUR_SECRET_KEY',
        }
      }
    }
    @pull_params = {
      :output_type => 'pull',
      :output_params => {
        :max_size => 52428800
      }
    }
    @datasift = DataSift::Client.new(@config)
  end

  attr_reader :datasift, :params

  def create_push(hash, is_historics_id = false)
    create_params = @params.merge ({
        #hash or historics_id can be used but not both
        :name           => 'My awesome push subscription',
        :initial_status => 'active', # or 'paused' or 'waiting_for_start'
    })
    if is_historics_id
      create_params.merge!({:historics_id => hash})
    else
      create_params.merge!({:hash  => hash,
                            #start and end are not valid for historics
                            :start => Time.now.to_i,
                            :end   => Time.now.to_i + 320
                           })
    end
    puts 'Creating subscription'
    subscription = @datasift.push.create create_params
    puts 'Create push => ' + subscription.to_s
    subscription
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
datasift-3.2.0	examples/auth.rb