Invocar um serviço do Google Cloud usando um conector

O Workflows publica conectores para facilitar o acesso a outras Google Cloud APIs em um fluxo de trabalho e integrar seus fluxos de trabalho a esses Google Cloud produtos. Por exemplo, é possível usar conectores para publicar mensagens do Pub/Sub, ler ou gravar dados em um banco de dados do Firestore ou recuperar chaves de autenticação do Secret Manager. Para uma referência detalhada dos conectores disponíveis, consulte a Referência de conectores.

Os conectores simplificam os serviços de chamada porque processam a formatação das solicitações, fornecendo métodos e argumentos para que você não precise conhecer os detalhes de uma API Google Cloud . Para saber mais sobre autenticação e comportamento durante novas tentativas e operações de longa duração, consulte Noções básicas sobre conectores.

Invocar uma chamada de conector

Assim como invocar um endpoint HTTP, uma chamada de conector requer os campos call e args. É possível especificar um valor de tempo limite e uma política de polling usando o bloco connector_params:

- STEP_NAME:
    call: CONNECTOR
    args:
        ARG: ARG_VALUE
        [...]
        body:
            KEY:KEY_VALUE
            [...]
        connector_params:
            timeout: TIMEOUT_IN_SECONDS
            polling_policy:
                initial_delay: INITIAL_DELAY_IN_SECONDS
                multiplier: MULTIPLIER_VALUE
                max_delay: MAX_DELAY_IN_SECONDS
            skip_polling: SKIP_POLLING_SWITCH 
            scopes:  OAUTH2_SCOPE 
    result: RESPONSE_VALUE

Substitua:

  • STEP_NAME: o nome da etapa.
  • CONNECTOR (obrigatório): o método do conector no formato googleapis.gcp_service.version.resource.operation. Por exemplo, googleapis.bigquery.v2.tables.get.
  • ARG e ARG_VALUE (obrigatório): cada chamada de conector requer argumentos diferentes.
  • KEY e KEY_VALUE (opcional): campos para fornecer entrada à API.
  • Parâmetros específicos do conector (opcional):
    • TIMEOUT_IN_SECONDS: tempo em segundos. A duração de ponta a ponta que a chamada do conector pode ser executada antes de gerar uma exceção de tempo limite. O valor padrão é 1800, que deve ser o máximo para métodos de conector que não são operações de longa duração. Caso contrário, para operações de longa duração, o tempo limite máximo de uma chamada de conector é de 31536000 segundos (um ano).
    • INITIAL_DELAY_IN_SECONDS: parâmetro de política de pesquisa com um valor padrão de 1.0. Aplicável apenas a chamadas de operações de longa duração.
    • MULTIPLIER_VALUE: parâmetro de política de pesquisa com um valor padrão de 1.25. Aplicável apenas a chamadas operação de longa duração.
    • MAX_DELAY_IN_SECONDS: parâmetro de política de pesquisa com um valor padrão de 60.0. Aplicável apenas a chamadas operação de longa duração.
    • SKIP_POLLING_SWITCH: se definido como True, a chamada de invocação do conector não será bloqueada se a solicitação inicial para gerenciar ou atualizar o recurso for bem-sucedida (geralmente HTTP POST, HTTP UPDATE ou HTTP DELETE). Se a solicitação inicial não for bem-sucedida, novas tentativas poderão ocorrer. A pesquisa de status (solicitações HTTP GET que seguem a solicitação inicial) é ignorada para a operação de longa duração após a conclusão da solicitação inicial. O valor padrão é False.
    • OAUTH2_SCOPE: escopos do OAuth2 a serem transmitidos para a API do Google. Pode ser uma string, uma lista de strings, uma string separada por espaços ou uma string separada por vírgulas.
  • RESPONSE_VALUE (opcional): nome da variável em que o resultado de uma etapa de invocação de chamada de conector é armazenado.

Exemplo

O fluxo de trabalho a seguir demonstra o uso do conector da API Cloud Storage e do conector da API Cloud Translation para traduzir dois arquivos para francês e espanhol, salvando os resultados em um bucket do Cloud Storage.

main:
  steps:
  - init:
      assign:
      - projectId: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
      - location: ${sys.get_env("GOOGLE_CLOUD_LOCATION")}
      - inputBucketName: ${projectId + "-input-files"}
      - outputBucketName: ${projectId + "-output-files-" + string(int(sys.now()))}
  - createOutputBucket:
        call: googleapis.storage.v1.buckets.insert
        args:
          project: ${projectId}
          body:
            name: ${outputBucketName}
  - batchTranslateText:
      call: googleapis.translate.v3beta1.projects.locations.batchTranslateText
      args:
          parent: ${"projects/" + projectId + "/locations/" + location}
          body:
              inputConfigs:
                gcsSource:
                  inputUri: ${"gs://" + inputBucketName + "/*"}
              outputConfig:
                  gcsDestination:
                    outputUriPrefix: ${"gs://" + outputBucketName + "/"}
              sourceLanguageCode: "en"
              targetLanguageCodes: ["es", "fr"]
      result: batchTranslateTextResult

A seguir