Sha256: 24593f94ba253771ebf23956269461e51a8e4b50de026d2e22b8a782cabc7290
Contents?: true
Size: 915 Bytes
Versions: 17
Compression:
Stored size: 915 Bytes
Contents
class TreasureData::API
module Import
####
## Import API
##
# @param [String] db
# @param [String] table
# @param [String] format
# @param [String, StringIO] stream
# @param [Fixnum] size
# @param [String] unique_id
# @return [Float] elapsed time
def import(db, table, format, stream, size, unique_id=nil)
if unique_id
path = "/v3/table/import_with_id/#{e db}/#{e table}/#{unique_id}/#{format}"
else
path = "/v3/table/import/#{e db}/#{e table}/#{format}"
end
opts = {}
if @host == DEFAULT_ENDPOINT
opts[:host] = DEFAULT_IMPORT_ENDPOINT
elsif @host == NEW_DEFAULT_ENDPOINT
opts[:host] = NEW_DEFAULT_IMPORT_ENDPOINT
end
code, body, res = put(path, stream, size, opts)
if code[0] != ?2
raise_error("Import failed", res)
end
js = checked_json(body, %w[])
time = js['elapsed_time'].to_f
return time
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems