class AzureQuery

Public Class Methods

new(logger, azure_table_service, table_name, query_str, query_id, entity_count_to_process) click to toggle source

# File lib/logstash/inputs/azurewadtable.rb, line 211
def initialize(logger, azure_table_service, table_name, query_str, query_id, entity_count_to_process)
  @logger = logger
  @query_str = query_str
  @query_id = query_id
  @entity_count_to_process = entity_count_to_process
  @azure_table_service = azure_table_service
  @table_name = table_name
  @continuation_token = nil
end

Public Instance Methods

id() click to toggle source

# File lib/logstash/inputs/azurewadtable.rb, line 225
def id
  return @query_id
end

reset() click to toggle source

# File lib/logstash/inputs/azurewadtable.rb, line 221
def reset
  @continuation_token = nil
end

run(on_result_cbk) click to toggle source

# File lib/logstash/inputs/azurewadtable.rb, line 229
def run(on_result_cbk)
  results_found = false
  @logger.debug("[#{@query_id}]Query filter: " + @query_str)
  begin
    @logger.debug("[#{@query_id}]Running query. continuation_token: #{@continuation_token}")
    query = { :top => @entity_count_to_process, :filter => @query_str, :continuation_token => @continuation_token }
    result = @azure_table_service.query_entities(@table_name, query)

    if result and result.length > 0
      results_found = true
      @logger.debug("[#{@query_id}] #{result.length} results found.")
      result.each do |entity|
        on_result_cbk.call(entity)
      end
    end

    @continuation_token = result.continuation_token
  end until !@continuation_token

  return results_found
end