Visão geral da publicação de mensagens

Para publicar uma mensagem com o Pub/Sub, um aplicativo editor cria e envia mensagens para um tópico.

Este documento apresenta uma visão geral do fluxo de trabalho de publicação, incluindo o conceito de tópicos e mensagens.

Sobre os temas

Um tópico do Pub/Sub é um recurso nomeado que representa um feed de mensagens. Quando um editor envia uma mensagem, ela é direcionada a um tópico específico. O serviço Pub/Sub usa esse nome para encaminhar a mensagem a todas as assinaturas anexadas ao tópico. Se houver vários assinantes para uma assinatura, apenas um deles vai receber a mensagem.

Os editores não precisam saber quantos assinantes existem. Eles se concentram no tópico, garantindo a separação das preocupações entre o envio e o recebimento de mensagens.

O Pub/Sub oferece suporte a dois tipos de tópicos: um padrão e um de importação.

Propriedades de um tema

Ao criar ou atualizar um tópico, é possível especificar as propriedades dele.

Para mais informações sobre as propriedades de um tópico, consulte Propriedades de um tópico.

Sobre os tópicos de importação

Um tópico de importação permite que o Pub/Sub ingira dados de streaming de outra fonte e atue como o aplicativo editor que envia os dados para o tópico. É possível ativar a transferência em um tópico usando o console, a Google Cloud CLI, chamadas REST ou as bibliotecas de cliente. Como parte do gerenciamento do tópico de importação, o Google Cloud oferece monitoramento e escalonamento do pipeline de ingestão.

Sem um tópico de importação, o streaming de dados para o Pub/Sub de uma fonte de dados exige um serviço adicional. Esse serviço extra extrai dados da fonte original e os publica no Pub/Sub. O serviço extra pode ser um mecanismo de streaming, como o Apache Spark ou um serviço personalizado. Você também precisa configurar, implantar, executar, dimensionar e monitorar esse serviço.

Confira a seguir uma lista de informações importantes sobre os tópicos de importação:

  • Assim como em um tópico padrão, ainda é possível publicar manualmente em um tópico de importação.

  • Só é possível anexar uma única origem de transferência a um tópico de importação.

Recomendamos importar tópicos para dados de streaming. Se você estiver considerando a ingestão de dados em lote no BigQuery em vez da ingestão de dados em streaming, tente usar o serviço de transferência de dados do BigQuery (BQ DTS). Se você quiser transferir dados para o Cloud Storage, o Storage Transfer Service (STS) é uma boa opção.

O Pub/Sub oferece suporte às seguintes origens para importar tópicos:

Replicação de dados em um tópico

Um tópico do Pub/Sub usa três zonas para armazenar dados. O serviço oferece suporte à replicação síncrona para pelo menos duas zonas e à replicação de melhor esforço para uma terceira zona. A replicação do Pub/Sub é em apenas uma região.

Sobre as mensagens

Uma mensagem do Pub/Sub são os dados transferidos pelo serviço.

Uma mensagem consiste em campos com os dados e os metadados da mensagem. Um dos seguintes precisa ser especificado em uma mensagem.

  • Dados da mensagem: é o conteúdo principal da mensagem e pode ser qualquer texto ou dados binários. Ele representa as informações que você quer comunicar entre editores e assinantes. Se você estiver usando a API REST diretamente, os dados da mensagem precisarão ser codificados em base64. Confira o exemplo na guia REST na seção Publicar mensagens.

  • Uma chave de ordenação: é um identificador que representa a entidade para a qual as mensagens precisam ser ordenadas. As mensagens com a mesma chave de ordenação precisam ser entregues a um assinante na ordem em que foram publicadas. Uma chave de ordenação só é necessária se você quiser o envio ordenado das mensagens. Para mais informações sobre a ordenação de chaves, consulte Ordem de mensagens.

  • Atributos: são pares de chave-valor opcionais que fornecem contexto e informações adicionais sobre a mensagem. Eles podem ser usados para rotear, filtrar ou enriquecer o conteúdo da mensagem. Por exemplo, é possível adicionar atributos como carimbos de data/hora ou IDs de transação. Para mais informações sobre os atributos usados na publicação de mensagens, consulte Usar atributos para publicar uma mensagem.

O serviço Pub/Sub adiciona os seguintes campos à mensagem:

  • Um ID de mensagem exclusivo para o tópico
  • Carimbo de data/hora de quando o serviço do Pub/Sub recebe a mensagem

Por exemplo, este é um formato de mensagem em JSON:

{
  "data": "This is the core message content.",
  "attributes": {
    "category": "notification",
    "user_id": "12345",
    "priority": "medium"
  },
    "orderingKey": "12345"
}

Fluxo de trabalho de publicação de mensagens

Para publicar uma mensagem com o Pub/Sub, um aplicativo do editor cria e envia mensagens para um tópico.

  1. Criar uma mensagem contendo seus dados.
  2. Selecione os atributos de publicação opcionais.
  3. Envie uma solicitação para o servidor do Pub/Sub publicar a mensagem em um tópico especificado.

  4. O serviço Pub/Sub recebe a mensagem e a processa da seguinte maneira:

    • A mensagem é armazenada para distribuição.

    • A mensagem é replicada em várias zonas para durabilidade e alta disponibilidade.

    • O Pub/Sub identifica assinantes com assinaturas que correspondem ao tópico da mensagem e entrega uma cópia dela a cada um deles.

O Pub/Sub oferece entrega de mensagens pelo menos uma vez e ordenação de melhor esforço para os assinantes atuais.

Para mais informações sobre o sistema do Pub/Sub, consulte Visão geral do serviço do Pub/Sub.

Para mais informações sobre como o Pub/Sub funciona, consulte Visão geral da arquitetura do Pub/Sub.

A seguir