Pubblicare messaggi in Pub/Sub dal mainframe

Mainframe Connector ti consente di pubblicare messaggi su Pub/Sub dal tuo mainframe. Puoi utilizzare questa funzionalità, ad esempio, per integrare il tuo mainframe con BigQuery o Cloud Storage, aumentare i dati dei messaggi con Dataflow o attivare le funzioni Cloud Run.

Prima di iniziare

Pubblicare un messaggio in un argomento Pub/Sub

Per pubblicare un messaggio Pub/Sub non strutturato dal mainframe, utilizza il comando pubsub topics publish come segue:

//STEP01 EXEC BQSH
//STDIN DD *
pubsub topics publish TOPIC --data="Hello,World"
/*

Sostituisci TOPIC con il nome dell'argomento Pub/Sub. Il formato richiesto è projects/{project}/topics/{topic}.

Pubblicare messaggi in un argomento Pub/Sub

Mainframe Connector ti consente di pubblicare messaggi strutturati da un mainframe in un argomento Pub/Sub. Ad esempio, puoi utilizzare questa funzionalità per trasferire i record QSAM (Queued Sequential Access Method) dal tuo mainframe a BigQuery utilizzando Pub/Sub. Di seguito sono riportati alcuni vantaggi dell'utilizzo di questo approccio:

  • Puoi trasformare i dati o aumentarli con AI tramite Dataflow o tramite il multithreading simultaneo (SMT) di Pub/Sub.
  • Puoi spostare i record da un mainframe a Cloud Storage.
  • Puoi sincronizzare gli aggiornamenti delle applicazioni mainframe con i sistemi basati su cloud in modo simile a Change Data Capture (CDC).

Per pubblicare messaggi strutturati dal mainframe in un argomento Pub/Sub, segui questi passaggi:

  1. Crea un argomento Pub/Sub per pubblicare i messaggi. Se vuoi, puoi creare un argomento con uno schema per applicare ulteriori restrizioni. Per ulteriori informazioni, consulta Creare un argomento o Creare e associare uno schema quando crei un argomento.
  2. Crea un argomento Pub/Sub per acquisire informazioni sui record che non riescono a essere transcodificati. Questo argomento è chiamato argomento spillover. Per informazioni sulla creazione di un argomento Pub/Sub, consulta Creare un argomento.
  3. (Facoltativo) Per convertire i record in JSON prima di inviarli a Pub/Sub, configura il file di configurazione JSON. Se non fornisci un file di configurazione, viene utilizzata la configurazione JSON predefinita.

  4. (Facoltativo) Per impostazione predefinita, i messaggi Pub/Sub non contengono chiavi di ordinamento e attributi. I messaggi di overflow vengono inviati all'argomento overflow con il suffisso _spillover. Per modificare i valori predefiniti, puoi configurare il file di configurazione di pubblicazione Pub/Sub. Ad esempio, puoi utilizzare la seguente configurazione:

    {
  "spillover-configuration": {
    "name": SPILLOVER_TOPIC_NAME
  }
}

    Sostituisci SPILLOVER_TOPIC_NAME con il nome dell'argomento spillover creato nel passaggio 2. Il formato richiesto è projects/{project}/topics/{topic}. Le informazioni sui messaggi che non vengono decodificati correttamente vengono salvate in questo argomento di overflow.

  5. Per pubblicare i record mainframe in Pub/Sub utilizzando il comando qsam decode, esegui il seguente JCL:

    //STEP01 EXEC BQSH
//STDIN DD *
qsam decode INPUT OUTPUT \
 --copybook COPYBOOK
 --transcode-configuration TRANSCODE-CONFIG
     --output-format=JSONL
     --input-parameter=json-dialect=JSON_CONFIGURATION
     --input-parameter=pubsub-publish-configuration=PUBSUB_CONFIGURATION
/*

    Sostituisci quanto segue: