File Manager

Hackfut Security File Manager

Current Path: /opt/td-agent/embedded/lib/ruby/gems/2.4.0/gems/td-client-1.0.7/lib/td/client/api

opt / td-agent / embedded / lib / ruby / gems / 2.4.0 / gems / td-client-1.0.7 / lib / td / client / api /

📁 ..
📄 account.rb(1.17 KB)
📄 bulk_import.rb(4.53 KB)
📄 bulk_load.rb(4.92 KB)
📄 database.rb(1.14 KB)
📄 export.rb(932 B)
📄 import.rb(979 B)
📄 job.rb(12.03 KB)
📄 partial_delete.rb(597 B)
📄 result.rb(997 B)
📄 schedule.rb(3.16 KB)
📄 server_status.rb(382 B)
📄 table.rb(4.16 KB)
📄 user.rb(3.34 KB)

Editing: bulk_import.rb

class TreasureData::API
module BulkImport

####
  ## Bulk import API
  ##

# @param [String] name
  # @param [String] db
  # @param [String] table
  # @param [Hash] opts
  # @return [nil]
  def create_bulk_import(name, db, table, opts={})
    params = opts.dup
    code, body, res = post("/v3/bulk_import/create/#{e name}/#{e db}/#{e table}", params)
    if code != "200"
      raise_error("Create bulk import failed", res)
    end
    return nil
  end

# @param [String] name
  # @param [Hash] opts
  # @return [nil]
  def delete_bulk_import(name, opts={})
    params = opts.dup
    code, body, res = post("/v3/bulk_import/delete/#{e name}", params)
    if code != "200"
      raise_error("Delete bulk import failed", res)
    end
    return nil
  end

# @param [String] name
  # @return [Hash]
  def show_bulk_import(name)
    code, body, res = get("/v3/bulk_import/show/#{name}")
    if code != "200"
      raise_error("Show bulk import failed", res)
    end
    js = checked_json(body, %w[status])
    return js
  end

# @param [Hash] opts
  # @return [Hash]
  def list_bulk_imports(opts={})
    params = opts.dup
    code, body, res = get("/v3/bulk_import/list", params)
    if code != "200"
      raise_error("List bulk imports failed", res)
    end
    js = checked_json(body, %w[bulk_imports])
    return js['bulk_imports']
  end

# @param [String] name
  # @param [Hash] opts
  # @return [nil]
  def list_bulk_import_parts(name, opts={})
    params = opts.dup
    code, body, res = get("/v3/bulk_import/list_parts/#{e name}", params)
    if code != "200"
      raise_error("List bulk import parts failed", res)
    end
    js = checked_json(body, %w[parts])
    return js['parts']
  end

# @param [String] name
  # @param [String] part_name
  # @param [String, StringIO] stream
  # @param [Fixnum] size
  # @param [Hash] opts
  # @return [nil]
  def bulk_import_upload_part(name, part_name, stream, size, opts={})
    code, body, res = put("/v3/bulk_import/upload_part/#{e name}/#{e part_name}", stream, size)
    if code[0] != ?2
      raise_error("Upload a part failed", res)
    end
    return nil
  end

# @param [String] name
  # @param [String] part_name
  # @param [Hash] opts
  # @return [nil]
  def bulk_import_delete_part(name, part_name, opts={})
    params = opts.dup
    code, body, res = post("/v3/bulk_import/delete_part/#{e name}/#{e part_name}", params)
    if code[0] != ?2
      raise_error("Delete a part failed", res)
    end
    return nil
  end

# @param [String] name
  # @param [Hash] opts
  # @return [nil]
  def freeze_bulk_import(name, opts={})
    params = opts.dup
    code, body, res = post("/v3/bulk_import/freeze/#{e name}", params)
    if code != "200"
      raise_error("Freeze bulk import failed", res)
    end
    return nil
  end

# @param [String] name
  # @param [Hash] opts
  # @return [nil]
  def unfreeze_bulk_import(name, opts={})
    params = opts.dup
    code, body, res = post("/v3/bulk_import/unfreeze/#{e name}", params)
    if code != "200"
      raise_error("Unfreeze bulk import failed", res)
    end
    return nil
  end

# @param [String] name
  # @param [Hash] opts
  # @return [String] job_id
  def perform_bulk_import(name, opts={})
    params = opts.dup
    code, body, res = post("/v3/bulk_import/perform/#{e name}", params)
    if code != "200"
      raise_error("Perform bulk import failed", res)
    end
    js = checked_json(body, %w[job_id])
    return js['job_id'].to_s
  end

# @param [String] name
  # @param [Hash] opts
  # @return [nil]
  def commit_bulk_import(name, opts={})
    params = opts.dup
    code, body, res = post("/v3/bulk_import/commit/#{e name}", params)
    if code != "200"
      raise_error("Commit bulk import failed", res)
    end
    return nil
  end

# @param [String] name
  # @param [Hash] opts
  # @param [Proc] block
  # @return [Array]
  def bulk_import_error_records(name, opts={}, &block)
    params = opts.dup
    code, body, res = get("/v3/bulk_import/error_records/#{e name}", params)
    if code != "200"
      raise_error("Failed to get bulk import error records", res)
    end
    if body.nil? || body.empty?
      if block
        return nil
      else
        return []
      end
    end
    require File.expand_path('../compat_gzip_reader', File.dirname(__FILE__))
    u = MessagePack::Unpacker.new(Zlib::GzipReader.new(StringIO.new(body)))
    if block
      begin
        u.each(&block)
      rescue EOFError
      end
      nil
    else
      result = []
      begin
        u.each {|row|
          result << row
        }
      rescue EOFError
      end
      return result
    end
  end

end
end

Hackfut Security File Manager

Editing: bulk_import.rb

Upload File

Create Folder