Crie um instantâneo do estado de uma tarefa de streaming (Ruby)

Demonstra como criar um instantâneo do estado de uma tarefa de streaming.

Exemplo de código

Ruby

Para se autenticar no Dataflow, configure as Credenciais padrão da aplicação. Para mais informações, consulte o artigo Configure a autenticação para um ambiente de desenvolvimento local.

require "google/cloud/dataflow/v1beta3"

##
# Snippet for the snapshot_job call in the Jobs service
#
# This snippet has been automatically generated and should be regarded as a code
# template only. It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
# client as shown in https://cloud.google.com/ruby/docs/reference.
#
# This is an auto-generated example demonstrating basic usage of
# Google::Cloud::Dataflow::V1beta3::Jobs::Client#snapshot_job.
#
def snapshot_job
  # Create a client object. The client can be reused for multiple calls.
  client = Google::Cloud::Dataflow::V1beta3::Jobs::Client.new

  # Create a request. To set request fields, pass in keyword arguments.
  request = Google::Cloud::Dataflow::V1beta3::SnapshotJobRequest.new

  # Call the snapshot_job method.
  result = client.snapshot_job request

  # The returned object is of type Google::Cloud::Dataflow::V1beta3::Snapshot.
  p result
end

O que se segue?

Para pesquisar e filtrar exemplos de código para outros Google Cloud produtos, consulte o Google Cloud navegador de exemplos.