Para desenvolver e testar seu aplicativo localmente, é possível usar o emulador do Pub/Sub, que fornece emulação local do serviço de produção do Pub/Sub. Você executa o emulador do Pub/Sub usando a CLI do Google Cloud.
Para executar seu aplicativo no emulador, primeiro inicie o emulador e defina as variáveis de ambiente. O aplicativo precisa se comunicar com o emulador em vez do serviço de Pub/Sub de produção. Os recursos criados e as mensagens publicadas no emulador são mantidos durante a vida útil da sessão dele.
Antes de começar
Atenda aos pré-requisitos a seguir antes de usar o Pub/Sub emulator:
Configure um ambiente de desenvolvimento em Python.
Instale um JDK.
Instale a CLI do Google Cloud.
Crie um aplicativo usando as Bibliotecas de cliente do Cloud.
Instalar o emulador
Instale o emulador no prompt de comando:
gcloud components install pubsub-emulator gcloud components update
Instalar o emulador como uma imagem de contêiner
Para instalar e executar o emulador como um contêiner, faça o download e instale a Imagem do gcloud Docker.
Iniciar o emulador
Invoque pubsub start
em um prompt de comando para iniciar o emulador. Antes
de executar o comando, substitua PUBSUB_PROJECT_ID por uma string válida
de ID do projeto do Google Cloud. A string não precisa
representam um projeto real do Google Cloud porque
O emulador do Pub/Sub é executado localmente.
gcloud beta emulators pubsub start --project=PUBSUB_PROJECT_ID [options]
Consulte gcloud beta emulators pubsub start
para ver uma lista completa de sinalizações.
Depois de iniciar o emulador, você verá uma mensagem semelhante a esta:
... [pubsub] This is the Pub/Sub fake. [pubsub] Implementation may be incomplete or differ from the real system. ... [pubsub] INFO: Server started, listening on 8085
Essa mensagem indica que o servidor do Pub/Sub é executado no endpoint do emulador na sua máquina local em vez do endpoint do Google Cloud. Todas as operações acontecer localmente, incluindo o seguinte:
- criação de um tópico ou de uma assinatura;
- publicação;
- Inscrição
Como definir variáveis de ambiente
Depois de iniciar o emulador, é necessário definir as variáveis de ambiente para que o aplicativo se conecte ao emulador em vez do Pub/Sub. Faça isso na mesma máquina usada na execução do seu aplicativo.
É necessário definir as variáveis de ambiente sempre que iniciar o emulador. Elas dependem de números de portas dinamicamente atribuídas que podem ser alteradas durante a reinicialização do emulador.
Como configurar automaticamente as variáveis
Se o aplicativo e o emulador forem executados na mesma máquina, defina as variáveis de ambiente automaticamente:
Linux/macOS
Execute env-init
usando a substituição de comando:
$(gcloud beta emulators pubsub env-init)
Windows
Crie e execute um arquivo de lote usando a saída de env-init
:
gcloud beta emulators pubsub env-init > set_vars.cmd && set_vars.cmd
O aplicativo se conectará ao emulador do Pub/Sub.
Como configurar manualmente as variáveis
Se o aplicativo e o emulador forem executados em máquinas diferentes, configure as variáveis de ambiente manualmente:
Execute o comando
env-init
:gcloud beta emulators pubsub env-init
Na máquina que executa o aplicativo, defina o valor e a variável de ambiente
PUBSUB_EMULATOR_HOST
de acordo com a direção da saída do comandoenv-init
. Essa configuração conecta seu aplicativo ao emulador. Também é possível definir o ambientePUBSUB_PROJECT_ID
no projeto que você quer usar para o emulador.Linux/macOS export PUBSUB_EMULATOR_HOST=[::1]:8432 export PUBSUB_PROJECT_ID=my-project-id
Windows set PUBSUB_EMULATOR_HOST=[::1]:8432 set PUBSUB_PROJECT_ID=my-project-id
O aplicativo se conectará ao emulador do Pub/Sub.
Observação: se você estiver usando a versão local do App Engine padrão para Python, servidor de desenvolvimento, você precisa passar essa variável de ambiente na linha de comando da seguinte forma:
dev_appserver.py app.yaml --env_var PUBSUB_EMULATOR_HOST=${PUBSUB_EMULATOR_HOST}
dev_appserver.py
está incluído no seu [PATH_TO_CLOUD_SDK]/google-cloud-sdk/bin/dev_appserver.py
.
Como usar o emulador
Para usar o emulador, você precisa ter um aplicativo criado com as bibliotecas de cliente do Cloud.
O emulador não é compatível com o console do Google Cloud nem com os comandos
gcloud pubsub
.
O exemplo a seguir demonstra o uso do emulador e de um aplicativo que usa o Biblioteca de cliente do Cloud para Python para executar várias operações. Exemplos dessas operações incluem como criar um tópico, publicar e ler mensagens.
Conclua as seguintes etapas no computador em que você configurou as variáveis de ambiente do emulador:
Faça o download das amostras do Pub/Sub para Python no GitHub. Para isso, clone o repositório inteiro do Python (em inglês).
Em seu repositório clonado, navegue até o diretório
samples/snippets
. Conclua o restante das etapas neste diretório.No diretório
samples/snippets
, instale as dependências necessárias para executar o exemplo:pip install -r requirements.txt
Crie um tópico:
python publisher.py PUBSUB_PROJECT_ID create TOPIC_ID
(Opcional) Se você não tiver um endpoint de push local para testar inscrições de push no emulador, conclua as etapas a seguir para criar um em
http://[::1]:3000/messages
.- Instale o servidor JSON.
npm install -g json-server
- Inicie o servidor JSON.
em quejson-server --port 3000 --watch db.json
db.json
contém o seguinte código inicial:{ "messages": [] }
- Anote
http://[::1]:3000/messages
para PUSH_ENDPOINT na próxima etapa.
- Instale o servidor JSON.
Crie uma assinatura para o tópico:
Crie uma assinatura de pull:
python subscriber.py PUBSUB_PROJECT_ID create TOPIC_ID SUBSCRIPTION_ID
Crie uma inscrição de push:
python subscriber.py PUBSUB_PROJECT_ID create-push TOPIC_ID SUBSCRIPTION_ID \ PUSH_ENDPOINT
Publique mensagens no tópico:
python publisher.py PUBSUB_PROJECT_ID publish TOPIC_ID
Leia as mensagens publicadas no tópico:
Recupere as mensagens da assinatura de pull:
python subscriber.py PUBSUB_PROJECT_ID receive SUBSCRIPTION_ID
Observe as mensagens entregues no endpoint de push local. Por exemplo, as mensagens têm esta aparência:
{ "messages": [ { "subscription": "projects/PUBSUB_PROJECT_ID/subscriptions/SUBSCRIPTION_ID", "message": { "data": "TWVzc2FnZSBudW1iZXIgMQ==", "messageId": "10", "attributes": {} }, "id": 1 }, ... ] }
Como acessar as variáveis de ambiente
Em todas as linguagens, exceto Java e C#, se você configurar PUBSUB_EMULATOR_HOST
conforme descrito em Como definir variáveis de ambiente, as bibliotecas de cliente do Pub/Sub chamarão automaticamente a API em execução na instância local em vez do Pub/Sub.
No entanto, é preciso modificar seu código para usar o emulador nas bibliotecas cliente C# e Java:
C#
Antes de testar esta amostra, siga as instruções de configuração do C# no Guia de início rápido do Pub/Sub: como usar bibliotecas de cliente. Para mais informações, consulte a documentação de referência da API Pub/Sub C#.
Para autenticar no Pub/Sub, configure o Application Default Credentials. Para mais informações, consulte Configurar a autenticação para um ambiente de desenvolvimento local.
Java
Antes de testar este exemplo, siga as instruções de configuração do Java na Guia de início rápido do Pub/Sub usando bibliotecas de cliente. Para mais informações, consulte a documentação de referência da API Pub/Sub Java.
Para autenticar no Pub/Sub, configure o Application Default Credentials. Para mais informações, consulte Configurar a autenticação para um ambiente de desenvolvimento local.
Interromper o emulador
Para interromper o emulador, pressione as teclas Ctrl+C.
Depois de interromper o emulador, execute o seguinte comando para remover a variável de ambiente PUBSUB_EMULATOR_HOST
para que o aplicativo se conecte ao Pub/Sub:
unset PUBSUB_EMULATOR_HOST
set PUBSUB_EMULATOR_HOST=
Argumentos de linha de comando do emulador
Consulte os detalhes sobre argumentos de linha de comando do emulador Pub/Sub em gcloud beta emulators pubsub
.
Recursos compatíveis
O emulador é compatível com os seguintes recursos do Pub/Sub:
- Como publicar mensagens
- Como receber mensagens de assinaturas de push e pull
- Como ordenar mensagens
- Como repetir mensagens
- Como encaminhar mensagens a tópicos de mensagens inativas
- Políticas de repetição na entrega de mensagens
- Compatibilidade do esquema para Avro
Limitações conhecidas
- As RPCs
UpdateTopic
eUpdateSnapshot
não são compatíveis. - As operações do IAM não são compatíveis.
- A retenção configurável de mensagens não é compatível. Todas as mensagens são retidas indefinidamente.
- A expiração da assinatura não é compatível. As assinaturas não expiram.
- A filtragem não é compatível.
- Compatibilidade do esquema para buffers de protocolo.
- As assinaturas do BigQuery podem ser criadas, mas não enviam mensagens para o BigQuery.
- Não é possível buscar um carimbo de data/hora para assinaturas ordenadas.
Para registrar problemas, envie um Issue Tracker público.
A seguir
- Para saber como usar o emulador do Pub/Sub com o minikube, consulte esta postagem do blog.