class Embulk::Input::ZendeskGuide

Public Class Methods

resume(task, columns, count) { |task, columns, count| ... } click to toggle source
# File lib/embulk/input/zendesk_guide.rb, line 25
def self.resume(task, columns, count)
  yield(task, columns, count)

  next_config_diff = {}
  next_config_diff
end
transaction(config, &control) click to toggle source
# File lib/embulk/input/zendesk_guide.rb, line 14
def self.transaction(config, &control)
  # configuration code:
  task = {
    'url' => config.param('url', :string),
    'username' => config.param('username', :string),
    'token' => config.param('token', :string)
  }
  columns = Articles.columns
  resume(task, columns, 1, &control)
end

Public Instance Methods

init() click to toggle source

TODO def self.guess(config)

sample_records = [
  {"example"=>"a", "column"=>1, "value"=>0.1},
  {"example"=>"a", "column"=>2, "value"=>0.2},
]
columns = Guess::SchemaGuess.from_hash_records(sample_records)
return {"columns" => columns}

end

# File lib/embulk/input/zendesk_guide.rb, line 42
def init
  @articles = Articles.new(task['url'], task['username'], task['token'])
end
run() click to toggle source
# File lib/embulk/input/zendesk_guide.rb, line 46
def run
  @articles.get.each do |article|
    page_builder.add(article)
  end

  page_builder.finish

  task_report = {}
  task_report
end