Contents

class DataSiftExample
  require '../lib/datasift'

  def initialize
    @username = 'DATASIFT_USERNAME'
    @api_key  = 'DATASIFT_API_KEY'
    @config   ={:username => @username, :api_key => @api_key, :enable_ssl => false}
    @params   = {
        :output_type                       => 's3',
        'output_params.bucket'             => 'apitests',
        'output_params.directory'          => 'ruby',
        'output_params.acl'                => 'private',
        'output_params.auth.access_key'    => 'AKIAIINK5C4FH75RSWNA',
        'output_params.auth.secret_key'    => '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',
        'output_params.delivery_frequency' => 0,
        'output_params.max_size'           => 10485760,
        'output_params.file_prefix'        => 'DataSift',
    }
    @datasift = DataSift::Client.new(@config)
  end

  attr_reader :datasift

  def create_push(hash, is_historics_id = false)
    create_params = @params.merge ({
        #hash or playback_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!({:playback_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.0.0.beta	examples/auth.rb