module Wechat::Concern::Qcloud
Public Instance Methods
invoke_cloud_function(function_name, post_body_params)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 6 def invoke_cloud_function(function_name, post_body_params) post 'invokecloudfunction', JSON.generate(post_body_params), params: { env: qcloud.qcloud_env, name: function_name }, base: Wechat::Api::TCB_BASE end
qdb_add(add_query)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 62 def qdb_add(add_query) post 'databaseadd', JSON.generate(env: qcloud.qcloud_env, query: add_query), base: Wechat::Api::TCB_BASE end
qdb_aggregate(aggregate_query)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 78 def qdb_aggregate(aggregate_query) post 'databaseaggregate', JSON.generate(env: qcloud.qcloud_env, query: aggregate_query), base: Wechat::Api::TCB_BASE end
qdb_collection_add(collection_name)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 43 def qdb_collection_add(collection_name) collection_add_params_hash = { env: qcloud.qcloud_env, collection_name: collection_name } post 'databasecollectionadd', JSON.generate(collection_add_params_hash), base: Wechat::Api::TCB_BASE end
qdb_collection_delete(collection_name)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 49 def qdb_collection_delete(collection_name) collection_delete_params_hash = { env: qcloud.qcloud_env, collection_name: collection_name } post 'databasecollectiondelete', JSON.generate(collection_delete_params_hash), base: Wechat::Api::TCB_BASE end
qdb_collections(limit: 10, offset: 0)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 55 def qdb_collections(limit: 10, offset: 0) get_collections_params_hash = { env: qcloud.qcloud_env, limit: limit, offset: offset } post 'databasecollectionget', JSON.generate(get_collections_params_hash), base: Wechat::Api::TCB_BASE end
qdb_count(count_query)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 82 def qdb_count(count_query) post 'databasecount', JSON.generate(env: qcloud.qcloud_env, query: count_query), base: Wechat::Api::TCB_BASE end
qdb_delete(delete_query)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 66 def qdb_delete(delete_query) post 'databasedelete', JSON.generate(env: qcloud.qcloud_env, query: delete_query), base: Wechat::Api::TCB_BASE end
qdb_migrate_export(query, file_path, file_type: Wechat::Qcloud::FILE_TYPE_JSON)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 20 def qdb_migrate_export(query, file_path, file_type: Wechat::Qcloud::FILE_TYPE_JSON) export_params_hash = { env: qcloud.qcloud_env, file_path: file_path, file_type: file_type, query: query } post 'databasemigrateexport', JSON.generate(export_params_hash), base: Wechat::Api::TCB_BASE end
qdb_migrate_import(collection_name, file_path, file_type: Wechat::Qcloud::FILE_TYPE_JSON, stop_on_error: false, conflict_mode: Wechat::Qcloud::CONFLICT_MODE_UPSERT)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 10 def qdb_migrate_import(collection_name, file_path, file_type: Wechat::Qcloud::FILE_TYPE_JSON, stop_on_error: false, conflict_mode: Wechat::Qcloud::CONFLICT_MODE_UPSERT) import_params_hash = { env: qcloud.qcloud_env, collection_name: collection_name, file_path: file_path, file_type: file_type, stop_on_error: stop_on_error, conflict_mode: conflict_mode } post 'databasemigrateimport', JSON.generate(import_params_hash), base: Wechat::Api::TCB_BASE end
qdb_migrate_query(job_id)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 28 def qdb_migrate_query(job_id) query_info_hash = { env: qcloud.qcloud_env, job_id: job_id } post 'databasemigratequeryinfo', JSON.generate(query_info_hash), base: Wechat::Api::TCB_BASE end
qdb_query(query)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 74 def qdb_query(query) post 'databasequery', JSON.generate(env: qcloud.qcloud_env, query: query), base: Wechat::Api::TCB_BASE end
qdb_update(update_query)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 70 def qdb_update(update_query) post 'databaseupdate', JSON.generate(env: qcloud.qcloud_env, query: update_query), base: Wechat::Api::TCB_BASE end
qdb_update_index(collection_name, create_indexes: [], drop_indexes: [])
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 35 def qdb_update_index(collection_name, create_indexes: [], drop_indexes: []) update_index_params_hash = { env: qcloud.qcloud_env, collection_name: collection_name, create_indexes: create_indexes, drop_indexes: drop_indexes } post 'updateindex', JSON.generate(update_index_params_hash), base: Wechat::Api::TCB_BASE end
tcb_delete_files(fileid_list)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 86 def tcb_delete_files(fileid_list) post 'batchdeletefile', JSON.generate(env: qcloud.qcloud_env, fileid_list: fileid_list), base: Wechat::Api::TCB_BASE end
tcb_do_upload_file(q_path, upload_url, signature, x_cos_security_token, x_cos_meta_fileid, file)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 98 def tcb_do_upload_file(q_path, upload_url, signature, x_cos_security_token, x_cos_meta_fileid, file) form_file = file.is_a?(HTTP::FormData::File) ? file : HTTP::FormData::File.new(file) form_data = HTTP::FormData.create({ key: q_path, Signature: signature, 'x-cos-security-token': x_cos_security_token, 'x-cos-meta-fileid': x_cos_meta_fileid, file: form_file }) client.httprb.post(upload_url, form: form_data, ssl_context: client.ssl_context) end
tcb_download_files(file_list)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 90 def tcb_download_files(file_list) post 'batchdownloadfile', JSON.generate(env: qcloud.qcloud_env, file_list: file_list), base: Wechat::Api::TCB_BASE end
tcb_preflight_upload_file(q_path)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 94 def tcb_preflight_upload_file(q_path) post 'uploadfile', JSON.generate(env: qcloud.qcloud_env, path: q_path), base: Wechat::Api::TCB_BASE end
tcb_upload_file(q_path, file)
click to toggle source
# File lib/wechat/concern/qcloud.rb, line 108 def tcb_upload_file(q_path, file) res = tcb_preflight_upload_file(q_path) tcb_do_upload_file(q_path, res['url'], res['authorization'], res['token'], res['cos_file_id'], file) res end