Consulte os conectores compatíveis com a Application Integration.

Gatilho do Cloud Pub/Sub

O gatilho do Cloud Pub/Sub permite executar sua integração com base nos eventos no seu middleware Pub/Sub.

Com esse gatilho, é possível executar uma integração sempre que um editor escreve uma mensagem no tópico escolhido por você. O tópico pode existir no mesmo projeto do Google Cloud que a integração ou em outro projeto do Google Cloud. Quando esse gatilho é executado, ele também grava a mensagem publicada na variável de saída CloudPubSubMessage. Com base nos seus requisitos, é possível usar essa variável nos gatilhos ou tarefas downstream.

Antes de começar

Execute as tarefas a seguir no projeto do Google Cloud antes de configurar o gatilho do Cloud Pub/Sub.

  • Atribua o Administrador do IAM do projeto (roles/resourcemanager.projectIamAdmin) ao usuário que está criando esse acionador.
  • Ative a API Pub/Sub para o projeto do Google Cloud que tem sua integração.
  • Confirme se você tem um tópico do Pub/Sub. Para criar um novo tópico do Pub/Sub:
    1. Acesse a página de tópicos do Pub/Sub no Console do Cloud

      Acesse a página de tópicos do Cloud Pub/Sub.

    2. Clique em Criar um tópico
    3. No campo ID do tópico, forneça um nome de tópico exclusivo.
    4. Clique em Salvar.

Para mais informações sobre como gerenciar o acesso usando papéis do IAM, consulte Controle de acesso.

Para informações sobre como conceder papéis a principais, consulte Como conceder, alterar e revogar acesso.

Adicionar um gatilho do Cloud Pub/Sub

Para adicionar um gatilho do Cloud Pub/Sub a uma integração nova ou existente, siga as etapas abaixo:
  1. No console do Google Cloud, acesse a página Application Integration.

    Acessar o Application Integration

  2. No menu de navegação, clique em Integrações.

    A página Lista de integrações aparece listando todas as integrações disponíveis no projeto do Google Cloud.

  3. Selecione uma integração existente ou clique em Criar integração para criar uma nova.

    Se você estiver criando uma integração:

    1. Digite um nome e uma descrição no painel Create Integration.
    2. Selecione uma região para a integração.
    3. Selecione uma conta de serviço para a integração. Você pode mudar ou atualizar os detalhes da conta de serviço de uma integração a qualquer momento no painel Resumo da integração na barra de ferramentas.
    4. Clique em Criar.

    Isso abre a integração na página do editor de integração.

  4. Na barra de navegação do editor de integração, clique em Gatilhos para conferir a lista de gatilhos disponíveis.
  5. Clique e posicione o elemento Gatilho do Cloud Pub/Sub no designer.

Configurar um gatilho do Cloud Pub/Sub

Clique no elemento de gatilho do Cloud Pub/Sub no editor de integração para exibir o painel de configuração do gatilho e faça o seguinte:

  1. Especifique o tópico que o gatilho ouvirá no campo Tópico do Pub/Sub no seguinte formato:
    projects/PROJECT_ID/topics/TOPIC_ID

    Para exibir todos os tópicos disponíveis no seu projeto do Google Cloud, confira a coluna Nome do tópico em Tópicos.

    Em que:
    • PROJECT_ID é o projeto do Google Cloud em que o tópico foi criado;
    • TOPIC_ID é o ID do tópico do Pub/Sub. O tópico pode estar no mesmo projeto do Google Cloud da sua integração ou em outro projeto do Google Cloud.
  2. Selecione a conta de serviço que você quer usar para o gatilho. A seleção de uma conta de serviço solicita que você conceda os papéis necessários. Para mais informações, consulte Papéis do IAM obrigatórios.

    Se não houver contas de serviço, crie uma clicando em Criar nova na lista suspensa Conta de serviço.

Papéis do IAM necessários para contas de serviço

Clique em Conceder ao selecionar uma conta de serviço para atribuir automaticamente os papéis a seguir às várias contas de serviço.

Conta de serviço Papel do IAM concedido
Conta de serviço padrão do Application Integration: service-PROJECT_NUMBER@gcp-sa-integrations.iam.gserviceaccount.com
  • Editor do Pub/Sub (roles/pubsub.editor)
  • Usuário da conta de serviço (roles/iam.serviceAccountUser)

Se o projeto do Google Cloud do tópico do Pub/Sub for diferente do projeto do Google Cloud da integração, a conta de serviço padrão precisará do papel Editor do Pub/Sub no projeto do Google Cloud do tópico.

Conta de serviço selecionada para o gatilho Invocador do Application Integration (roles/integrations.integrationInvoker)

Saída do gatilho

Para cada evento, o acionador do Cloud Pub/Sub gera uma variável de saída CloudPubSubMessage que pode ser usada nas tarefas downstream. A variável está no formato JSON e tem a estrutura PubsubMessage.

Considerações

  • O tamanho máximo de uma mensagem do Pub/Sub é de 10 MB. Para entender todas as limitações do Pub/Sub, consulte Cotas e limites do Pub/Sub.
  • É possível que o Pub/Sub escreva a mesma mensagem mais de uma vez em um tópico. Para entender esse comportamento do Pub/Sub, consulte Entrega pelo menos uma vez. Por isso, você precisa projetar a integração como idempotente para que ela não permita que uma mensagem seja gravada mais de uma vez em um tópico.

Criar assinatura com filtro para sua integração

Se você quiser definir um filtro para a assinatura do Pub/Sub processar eventos específicos na sua integração, siga estas etapas:

  1. Publique a integração com o gatilho do Cloud Pub/Sub configurado. Nesta etapa, a assinatura é criada no projeto de integração.
  2. No Console do Google Cloud, acesse a página Assinaturas.

    Acessar "Assinaturas"

  3. Abra a assinatura e copie todos os detalhes, incluindo o nome dela.
  4. Exclua a assinatura.
  5. Crie uma nova assinatura com todos os detalhes da assinatura excluída, incluindo o nome, que você copiou na etapa 3 e adicione um filtro a ela.

    A assinatura recém-criada aciona a integração com as mensagens filtradas.

Exclusões do SLA

O gatilho do Cloud Pub/Sub depende do produto Pub/Sub. Como essa dependência é externa à Application Integration, os termos e condições do contrato de nível de serviço (SLA) da Application Integration são aplicáveis somente quando o gatilho do Cloud Pub/Sub inicia a execução de uma integração active.