O Mainframe Connector permite-lhe publicar mensagens no Pub/Sub a partir do seu mainframe. Pode usar esta funcionalidade, por exemplo, para integrar o seu mainframe com o BigQuery ou o Cloud Storage, aumentar os dados das mensagens com o Dataflow ou acionar funções do Cloud Run.
Antes de começar
- Se ainda não o fez, instale o Mainframe Connector no mainframe.
- Para executar comandos do Pub/Sub, verifique se atribui a função de publicador do Pub/Sub à sua conta de utilizador. Para informações sobre a atribuição de funções a uma conta de utilizador, consulte o artigo Gerir o acesso através da IAM.
- Configure as Credenciais padrão da aplicação.
Publicar uma mensagem num tópico do Pub/Sub
Para publicar uma mensagem Pub/Sub não estruturada a partir do seu mainframe,
use o comando pubsub topics publish
da seguinte forma:
//STEP01 EXEC BQSH //STDIN DD * pubsub topics publish TOPIC --data="Hello,World" /*
Substitua TOPIC
pelo nome do tópico do Pub/Sub. O formato necessário é projects/{project}/topics/{topic}
.
Publicar mensagens num tópico do Pub/Sub
O conetor de mainframe permite-lhe publicar mensagens estruturadas de um mainframe num tópico do Pub/Sub. Por exemplo, pode usar esta capacidade para transferir registos do método de acesso sequencial em fila (QSAM) do seu mainframe para o BigQuery através do Pub/Sub. Seguem-se algumas das vantagens de usar esta abordagem:
- Pode transformar ou aumentar os dados com IA através do Dataflow ou através da multiprocessamento simultâneo (SMTs) do Pub/Sub.
- Pode mover registos de um mainframe para o Cloud Storage.
- Pode sincronizar atualizações de aplicações de mainframe com sistemas baseados na nuvem, de forma semelhante à captura de dados de alterações (CDC).
Para publicar mensagens estruturadas do seu mainframe num tópico do Pub/Sub, use os seguintes passos:
- Crie um tópico Pub/Sub para publicar mensagens. Opcionalmente, pode criar um tópico com um esquema para mais restrições. Para mais informações, consulte Crie um tópico ou Crie e associe um esquema quando criar um tópico.
- Crie um tópico do Pub/Sub para capturar informações sobre registos que não são transcodificados. Este tópico é denominado tópico de transbordo. Para informações sobre como criar um tópico do Pub/Sub, consulte Crie um tópico.
- (Opcional) Para converter os registos em JSON antes de os enviar para o Pub/Sub, configure o ficheiro de configuração JSON. Se não fornecer um ficheiro de configuração, é usada a configuração JSON predefinida.
(Opcional) Por predefinição, as mensagens Pub/Sub não contêm chaves de ordenação nem atributos. As mensagens de transbordo são enviadas para o tópico de transbordo com o sufixo
_spillover
. Para alterar as predefinições, pode configurar o ficheiro de configuração de publicação do Pub/Sub. Por exemplo, pode usar a seguinte configuração:{ "spillover-configuration": { "name": SPILLOVER_TOPIC_NAME } }
Substitua
SPILLOVER_TOPIC_NAME
pelo nome do tópico de transbordo que criou no passo 2. O formato necessário éprojects/{project}/topics/{topic}
. As informações sobre mensagens que não são descodificadas corretamente são guardadas neste tópico de transbordo.Para publicar registos de mainframe no Pub/Sub através do comando
qsam decode
, execute o seguinte JCL://STEP01 EXEC BQSH //STDIN DD * qsam decode
INPUT
OUTPUT
\ --copybookCOPYBOOK
--transcode-configurationTRANSCODE-CONFIG
--output-format=JSONL --input-parameter=json-dialect=JSON_CONFIGURATION
--input-parameter=pubsub-publish-configuration=PUBSUB_CONFIGURATION
/*Substitua o seguinte:
INPUT
: o caminho dos dados do ficheiro QSAM.OUTPUT
: o caminho de dados do tópico do Pub/Sub que criou no passo 1. O formato necessário épubsub:projects/{project}/topics/{topic}
.TRANSCODE-CONFIG
: o caminho dos dados do ficheiro que contém a configuração da transcodificação. Para mais informações sobre o formato de configuração do transcodificador, consulte o artigo Configuração do transcodificador.JSON_CONFIGURATION
: (opcional) o caminho dos dados do ficheiro de configuração JSON. Se não fornecer um ficheiro de configuração, é usada a configuração JSON predefinida.PUBSUB_CONFIGURATION
: (opcional) o caminho de dados do ficheiro de configuração de publicação do Pub/Sub. Se não especificar um ficheiro de configuração, é usada a configuração predefinida do Pub/Sub.