Class: Google::Cloud::Bigquery::DataTransfer::V1::DataTransferServiceClient
- Inherits:
-
Object
- Object
- Google::Cloud::Bigquery::DataTransfer::V1::DataTransferServiceClient
- Defined in:
- lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb
Overview
The Google BigQuery Data Transfer Service API enables BigQuery users to configure the transfer of their data from other Google Products into BigQuery. This service contains methods that are end user exposed. It backs up the frontend.
Constant Summary collapse
- SERVICE_ADDRESS =
The default address of the service.
"bigquerydatatransfer.googleapis.com".freeze
- DEFAULT_SERVICE_PORT =
The default port of the service.
443
- GRPC_INTERCEPTORS =
The default set of gRPC interceptors.
[]
- DEFAULT_TIMEOUT =
30
- ALL_SCOPES =
The scopes needed to make gRPC calls to all of the methods defined in this service.
[ "https://www.googleapis.com/auth/cloud-platform" ].freeze
Class Method Summary collapse
-
.location_data_source_path(project, location, data_source) ⇒ String
Returns a fully-qualified location_data_source resource name string.
-
.location_path(project, location) ⇒ String
Returns a fully-qualified location resource name string.
-
.location_run_path(project, location, transfer_config, run) ⇒ String
Returns a fully-qualified location_run resource name string.
-
.location_transfer_config_path(project, location, transfer_config) ⇒ String
Returns a fully-qualified location_transfer_config resource name string.
-
.project_data_source_path(project, data_source) ⇒ String
Returns a fully-qualified project_data_source resource name string.
-
.project_path(project) ⇒ String
Returns a fully-qualified project resource name string.
-
.project_run_path(project, transfer_config, run) ⇒ String
Returns a fully-qualified project_run resource name string.
-
.project_transfer_config_path(project, transfer_config) ⇒ String
Returns a fully-qualified project_transfer_config resource name string.
Instance Method Summary collapse
-
#check_valid_creds(name, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::CheckValidCredsResponse
Returns true if valid credentials exist for the given data source and requesting user.
-
#create_transfer_config(parent, transfer_config, authorization_code: nil, version_info: nil, service_account_name: nil, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::TransferConfig
Creates a new data transfer configuration.
-
#delete_transfer_config(name, options: nil) {|result, operation| ... } ⇒ Object
Deletes a data transfer configuration, including any associated transfer runs and logs.
-
#delete_transfer_run(name, options: nil) {|result, operation| ... } ⇒ Object
Deletes the specified transfer run.
-
#get_data_source(name, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::DataSource
Retrieves a supported data source and returns its settings, which can be used for UI rendering.
-
#get_transfer_config(name, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::TransferConfig
Returns information about a data transfer config.
-
#get_transfer_run(name, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::TransferRun
Returns information about the particular transfer run.
-
#initialize(credentials: nil, scopes: ALL_SCOPES, client_config: {}, timeout: DEFAULT_TIMEOUT, metadata: nil, service_address: nil, service_port: nil, exception_transformer: nil, lib_name: nil, lib_version: "") ⇒ DataTransferServiceClient
constructor
A new instance of DataTransferServiceClient.
-
#list_data_sources(parent, page_size: nil, options: nil) {|result, operation| ... } ⇒ Google::Gax::PagedEnumerable<Google::Cloud::Bigquery::Datatransfer::V1::DataSource>
Lists supported data sources and returns their settings, which can be used for UI rendering.
-
#list_transfer_configs(parent, data_source_ids: nil, page_size: nil, options: nil) {|result, operation| ... } ⇒ Google::Gax::PagedEnumerable<Google::Cloud::Bigquery::Datatransfer::V1::TransferConfig>
Returns information about all data transfers in the project.
-
#list_transfer_logs(parent, page_size: nil, message_types: nil, options: nil) {|result, operation| ... } ⇒ Google::Gax::PagedEnumerable<Google::Cloud::Bigquery::Datatransfer::V1::TransferMessage>
Returns user facing log messages for the data transfer run.
-
#list_transfer_runs(parent, states: nil, page_size: nil, run_attempt: nil, options: nil) {|result, operation| ... } ⇒ Google::Gax::PagedEnumerable<Google::Cloud::Bigquery::Datatransfer::V1::TransferRun>
Returns information about running and completed jobs.
-
#schedule_transfer_runs(parent, start_time, end_time, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::ScheduleTransferRunsResponse
Creates transfer runs for a time range [start_time, end_time].
-
#start_manual_transfer_runs(parent: nil, requested_time_range: nil, requested_run_time: nil, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::StartManualTransferRunsResponse
Start manual transfer runs to be executed now with schedule_time equal to current time.
-
#update_transfer_config(transfer_config, update_mask, authorization_code: nil, version_info: nil, service_account_name: nil, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::TransferConfig
Updates a data transfer configuration.
Constructor Details
#initialize(credentials: nil, scopes: ALL_SCOPES, client_config: {}, timeout: DEFAULT_TIMEOUT, metadata: nil, service_address: nil, service_port: nil, exception_transformer: nil, lib_name: nil, lib_version: "") ⇒ DataTransferServiceClient
Returns a new instance of DataTransferServiceClient.
264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 264 def initialize \ credentials: nil, scopes: ALL_SCOPES, client_config: {}, timeout: DEFAULT_TIMEOUT, metadata: nil, service_address: nil, service_port: nil, exception_transformer: nil, lib_name: nil, lib_version: "" # These require statements are intentionally placed here to initialize # the gRPC module only when it's required. # See https://github.com/googleapis/toolkit/issues/446 require "google/gax/grpc" require "google/cloud/bigquery/datatransfer/v1/datatransfer_services_pb" credentials ||= Google::Cloud::Bigquery::DataTransfer::V1::Credentials.default if credentials.is_a?(String) || credentials.is_a?(Hash) updater_proc = Google::Cloud::Bigquery::DataTransfer::V1::Credentials.new(credentials).updater_proc end if credentials.is_a?(GRPC::Core::Channel) channel = credentials end if credentials.is_a?(GRPC::Core::ChannelCredentials) chan_creds = credentials end if credentials.is_a?(Proc) updater_proc = credentials end if credentials.is_a?(Google::Auth::Credentials) updater_proc = credentials.updater_proc end package_version = Google::Cloud::Bigquery::DataTransfer::VERSION google_api_client = "gl-ruby/#{RUBY_VERSION}" google_api_client << " #{lib_name}/#{lib_version}" if lib_name google_api_client << " gapic/#{package_version} gax/#{Google::Gax::VERSION}" google_api_client << " grpc/#{GRPC::VERSION}" google_api_client.freeze headers = { :"x-goog-api-client" => google_api_client } headers.merge!() unless .nil? client_config_file = Pathname.new(__dir__).join( "data_transfer_service_client_config.json" ) defaults = client_config_file.open do |f| Google::Gax.construct_settings( "google.cloud.bigquery.datatransfer.v1.DataTransferService", JSON.parse(f.read), client_config, Google::Gax::Grpc::STATUS_CODE_NAMES, timeout, page_descriptors: PAGE_DESCRIPTORS, errors: Google::Gax::Grpc::API_ERRORS, metadata: headers ) end # Allow overriding the service path/port in subclasses. service_path = service_address || self.class::SERVICE_ADDRESS port = service_port || self.class::DEFAULT_SERVICE_PORT interceptors = self.class::GRPC_INTERCEPTORS @data_transfer_service_stub = Google::Gax::Grpc.create_stub( service_path, port, chan_creds: chan_creds, channel: channel, updater_proc: updater_proc, scopes: scopes, interceptors: interceptors, &Google::Cloud::Bigquery::Datatransfer::V1::DataTransferService::Stub.method(:new) ) @get_data_source = Google::Gax.create_api_call( @data_transfer_service_stub.method(:get_data_source), defaults["get_data_source"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'name' => request.name} end ) @list_data_sources = Google::Gax.create_api_call( @data_transfer_service_stub.method(:list_data_sources), defaults["list_data_sources"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'parent' => request.parent} end ) @create_transfer_config = Google::Gax.create_api_call( @data_transfer_service_stub.method(:create_transfer_config), defaults["create_transfer_config"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'parent' => request.parent} end ) @update_transfer_config = Google::Gax.create_api_call( @data_transfer_service_stub.method(:update_transfer_config), defaults["update_transfer_config"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'transfer_config.name' => request.transfer_config.name} end ) @delete_transfer_config = Google::Gax.create_api_call( @data_transfer_service_stub.method(:delete_transfer_config), defaults["delete_transfer_config"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'name' => request.name} end ) @get_transfer_config = Google::Gax.create_api_call( @data_transfer_service_stub.method(:get_transfer_config), defaults["get_transfer_config"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'name' => request.name} end ) @list_transfer_configs = Google::Gax.create_api_call( @data_transfer_service_stub.method(:list_transfer_configs), defaults["list_transfer_configs"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'parent' => request.parent} end ) @schedule_transfer_runs = Google::Gax.create_api_call( @data_transfer_service_stub.method(:schedule_transfer_runs), defaults["schedule_transfer_runs"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'parent' => request.parent} end ) @get_transfer_run = Google::Gax.create_api_call( @data_transfer_service_stub.method(:get_transfer_run), defaults["get_transfer_run"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'name' => request.name} end ) @delete_transfer_run = Google::Gax.create_api_call( @data_transfer_service_stub.method(:delete_transfer_run), defaults["delete_transfer_run"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'name' => request.name} end ) @list_transfer_runs = Google::Gax.create_api_call( @data_transfer_service_stub.method(:list_transfer_runs), defaults["list_transfer_runs"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'parent' => request.parent} end ) @list_transfer_logs = Google::Gax.create_api_call( @data_transfer_service_stub.method(:list_transfer_logs), defaults["list_transfer_logs"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'parent' => request.parent} end ) @check_valid_creds = Google::Gax.create_api_call( @data_transfer_service_stub.method(:check_valid_creds), defaults["check_valid_creds"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'name' => request.name} end ) @start_manual_transfer_runs = Google::Gax.create_api_call( @data_transfer_service_stub.method(:start_manual_transfer_runs), defaults["start_manual_transfer_runs"], exception_transformer: exception_transformer, params_extractor: proc do |request| {'parent' => request.parent} end ) end |
Class Method Details
.location_data_source_path(project, location, data_source) ⇒ String
Returns a fully-qualified location_data_source resource name string.
151 152 153 154 155 156 157 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 151 def self.location_data_source_path project, location, data_source LOCATION_DATA_SOURCE_PATH_TEMPLATE.render( :"project" => project, :"location" => location, :"data_source" => data_source ) end |
.location_path(project, location) ⇒ String
Returns a fully-qualified location resource name string.
139 140 141 142 143 144 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 139 def self.location_path project, location LOCATION_PATH_TEMPLATE.render( :"project" => project, :"location" => location ) end |
.location_run_path(project, location, transfer_config, run) ⇒ String
Returns a fully-qualified location_run resource name string.
165 166 167 168 169 170 171 172 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 165 def self.location_run_path project, location, transfer_config, run LOCATION_RUN_PATH_TEMPLATE.render( :"project" => project, :"location" => location, :"transfer_config" => transfer_config, :"run" => run ) end |
.location_transfer_config_path(project, location, transfer_config) ⇒ String
Returns a fully-qualified location_transfer_config resource name string.
179 180 181 182 183 184 185 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 179 def self.location_transfer_config_path project, location, transfer_config LOCATION_TRANSFER_CONFIG_PATH_TEMPLATE.render( :"project" => project, :"location" => location, :"transfer_config" => transfer_config ) end |
.project_data_source_path(project, data_source) ⇒ String
Returns a fully-qualified project_data_source resource name string.
200 201 202 203 204 205 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 200 def self.project_data_source_path project, data_source PROJECT_DATA_SOURCE_PATH_TEMPLATE.render( :"project" => project, :"data_source" => data_source ) end |
.project_path(project) ⇒ String
Returns a fully-qualified project resource name string.
190 191 192 193 194 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 190 def self.project_path project PROJECT_PATH_TEMPLATE.render( :"project" => project ) end |
.project_run_path(project, transfer_config, run) ⇒ String
Returns a fully-qualified project_run resource name string.
212 213 214 215 216 217 218 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 212 def self.project_run_path project, transfer_config, run PROJECT_RUN_PATH_TEMPLATE.render( :"project" => project, :"transfer_config" => transfer_config, :"run" => run ) end |
.project_transfer_config_path(project, transfer_config) ⇒ String
Returns a fully-qualified project_transfer_config resource name string.
224 225 226 227 228 229 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 224 def self.project_transfer_config_path project, transfer_config PROJECT_TRANSFER_CONFIG_PATH_TEMPLATE.render( :"project" => project, :"transfer_config" => transfer_config ) end |
Instance Method Details
#check_valid_creds(name, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::CheckValidCredsResponse
Returns true if valid credentials exist for the given data source and requesting user. Some data sources doesn't support service account, so we need to talk to them on behalf of the end user. This API just checks whether we have OAuth token for the particular user, which is a pre-requisite before user can create a transfer config.
1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 1100 def check_valid_creds \ name, options: nil, &block req = { name: name }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::CheckValidCredsRequest) @check_valid_creds.call(req, , &block) end |
#create_transfer_config(parent, transfer_config, authorization_code: nil, version_info: nil, service_account_name: nil, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::TransferConfig
Creates a new data transfer configuration.
604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 604 def create_transfer_config \ parent, transfer_config, authorization_code: nil, version_info: nil, service_account_name: nil, options: nil, &block req = { parent: parent, transfer_config: transfer_config, authorization_code: , version_info: version_info, service_account_name: service_account_name }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::CreateTransferConfigRequest) @create_transfer_config.call(req, , &block) end |
#delete_transfer_config(name, options: nil) {|result, operation| ... } ⇒ Object
Deletes a data transfer configuration, including any associated transfer runs and logs.
724 725 726 727 728 729 730 731 732 733 734 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 724 def delete_transfer_config \ name, options: nil, &block req = { name: name }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::DeleteTransferConfigRequest) @delete_transfer_config.call(req, , &block) nil end |
#delete_transfer_run(name, options: nil) {|result, operation| ... } ⇒ Object
Deletes the specified transfer run.
936 937 938 939 940 941 942 943 944 945 946 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 936 def delete_transfer_run \ name, options: nil, &block req = { name: name }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::DeleteTransferRunRequest) @delete_transfer_run.call(req, , &block) nil end |
#get_data_source(name, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::DataSource
Retrieves a supported data source and returns its settings, which can be used for UI rendering.
478 479 480 481 482 483 484 485 486 487 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 478 def get_data_source \ name, options: nil, &block req = { name: name }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::GetDataSourceRequest) @get_data_source.call(req, , &block) end |
#get_transfer_config(name, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::TransferConfig
Returns information about a data transfer config.
757 758 759 760 761 762 763 764 765 766 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 757 def get_transfer_config \ name, options: nil, &block req = { name: name }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::GetTransferConfigRequest) @get_transfer_config.call(req, , &block) end |
#get_transfer_run(name, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::TransferRun
Returns information about the particular transfer run.
905 906 907 908 909 910 911 912 913 914 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 905 def get_transfer_run \ name, options: nil, &block req = { name: name }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::GetTransferRunRequest) @get_transfer_run.call(req, , &block) end |
#list_data_sources(parent, page_size: nil, options: nil) {|result, operation| ... } ⇒ Google::Gax::PagedEnumerable<Google::Cloud::Bigquery::Datatransfer::V1::DataSource>
Lists supported data sources and returns their settings, which can be used for UI rendering.
533 534 535 536 537 538 539 540 541 542 543 544 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 533 def list_data_sources \ parent, page_size: nil, options: nil, &block req = { parent: parent, page_size: page_size }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::ListDataSourcesRequest) @list_data_sources.call(req, , &block) end |
#list_transfer_configs(parent, data_source_ids: nil, page_size: nil, options: nil) {|result, operation| ... } ⇒ Google::Gax::PagedEnumerable<Google::Cloud::Bigquery::Datatransfer::V1::TransferConfig>
Returns information about all data transfers in the project.
813 814 815 816 817 818 819 820 821 822 823 824 825 826 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 813 def list_transfer_configs \ parent, data_source_ids: nil, page_size: nil, options: nil, &block req = { parent: parent, data_source_ids: data_source_ids, page_size: page_size }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::ListTransferConfigsRequest) @list_transfer_configs.call(req, , &block) end |
#list_transfer_logs(parent, page_size: nil, message_types: nil, options: nil) {|result, operation| ... } ⇒ Google::Gax::PagedEnumerable<Google::Cloud::Bigquery::Datatransfer::V1::TransferMessage>
Returns user facing log messages for the data transfer run.
1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 1059 def list_transfer_logs \ parent, page_size: nil, message_types: nil, options: nil, &block req = { parent: parent, page_size: page_size, message_types: }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::ListTransferLogsRequest) @list_transfer_logs.call(req, , &block) end |
#list_transfer_runs(parent, states: nil, page_size: nil, run_attempt: nil, options: nil) {|result, operation| ... } ⇒ Google::Gax::PagedEnumerable<Google::Cloud::Bigquery::Datatransfer::V1::TransferRun>
Returns information about running and completed jobs.
996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 996 def list_transfer_runs \ parent, states: nil, page_size: nil, run_attempt: nil, options: nil, &block req = { parent: parent, states: states, page_size: page_size, run_attempt: run_attempt }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::ListTransferRunsRequest) @list_transfer_runs.call(req, , &block) end |
#schedule_transfer_runs(parent, start_time, end_time, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::ScheduleTransferRunsResponse
Creates transfer runs for a time range [start_time, end_time]. For each date - or whatever granularity the data source supports - in the range, one transfer run is created. Note that runs are created per UTC time in the time range. DEPRECATED: use StartManualTransferRuns instead.
869 870 871 872 873 874 875 876 877 878 879 880 881 882 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 869 def schedule_transfer_runs \ parent, start_time, end_time, options: nil, &block req = { parent: parent, start_time: start_time, end_time: end_time }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::ScheduleTransferRunsRequest) @schedule_transfer_runs.call(req, , &block) end |
#start_manual_transfer_runs(parent: nil, requested_time_range: nil, requested_run_time: nil, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::StartManualTransferRunsResponse
Start manual transfer runs to be executed now with schedule_time equal to current time. The transfer runs can be created for a time range where the run_time is between start_time (inclusive) and end_time (exclusive), or for a specific run_time.
1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 1143 def start_manual_transfer_runs \ parent: nil, requested_time_range: nil, requested_run_time: nil, options: nil, &block req = { parent: parent, requested_time_range: requested_time_range, requested_run_time: requested_run_time }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::StartManualTransferRunsRequest) @start_manual_transfer_runs.call(req, , &block) end |
#update_transfer_config(transfer_config, update_mask, authorization_code: nil, version_info: nil, service_account_name: nil, options: nil) {|result, operation| ... } ⇒ Google::Cloud::Bigquery::Datatransfer::V1::TransferConfig
Updates a data transfer configuration. All fields must be set, even if they are not updated.
684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 |
# File 'lib/google/cloud/bigquery/data_transfer/v1/data_transfer_service_client.rb', line 684 def update_transfer_config \ transfer_config, update_mask, authorization_code: nil, version_info: nil, service_account_name: nil, options: nil, &block req = { transfer_config: transfer_config, update_mask: update_mask, authorization_code: , version_info: version_info, service_account_name: service_account_name }.delete_if { |_, v| v.nil? } req = Google::Gax::to_proto(req, Google::Cloud::Bigquery::Datatransfer::V1::UpdateTransferConfigRequest) @update_transfer_config.call(req, , &block) end |