Contents

class DataSiftExample
  require 'datasift'

  def initialize
    @config = {
      username: 'DATASIFT_USERNAME',
      api_key: 'DATASIFT_API_KEY',
      api_version: 'v1.2'
    }
    @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
      # Start and end are not valid for historics
      create_params.merge!(
        hash: hash,
        start: Time.now.to_i,
        end: Time.now.to_i + 320
      )
    end
    puts 'Creating subscription'
    @datasift.push.create create_params
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
datasift-3.5.2	examples/auth.rb
datasift-3.5.1	examples/auth.rb
datasift-3.5.0	examples/auth.rb