Publica mensajes en Pub/Sub desde tu mainframe

Mainframe Connector te permite publicar mensajes en Pub/Sub desde tu mainframe. Puedes usar esta función, por ejemplo, para integrar tu mainframe con BigQuery o Cloud Storage, aumentar los datos de los mensajes con Dataflow o activar funciones de Cloud Run.

Antes de comenzar

Publica un mensaje en un tema de Pub/Sub

Para publicar un mensaje de Pub/Sub no estructurado desde tu sistema central, usa el comando pubsub topics publish de la siguiente manera:

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

Reemplaza TOPIC por el nombre del tema de Pub/Sub. El formato obligatorio es projects/{project}/topics/{topic}.

Publica mensajes en un tema de Pub/Sub

El conector de Mainframe te permite publicar mensajes estructurados desde un mainframe en un tema de Pub/Sub. Por ejemplo, puedes usar esta función para transferir registros del método de acceso secuencial en cola (QSAM) de tu mainframe a BigQuery con Pub/Sub. Estas son algunas de las ventajas de usar este enfoque:

  • Puedes transformar datos o aumentarlos con IA a través de Dataflow o a través de la multitarea simultánea (SMT) de Pub/Sub.
  • Puedes mover registros de un mainframe a Cloud Storage.
  • Puedes sincronizar las actualizaciones de las aplicaciones de la unidad central con sistemas basados en la nube similares a la captura de datos modificados (CDC).

Para publicar mensajes estructurados desde tu mainframe en un tema de Pub/Sub, sigue estos pasos:

  1. Crea un tema de Pub/Sub para publicar mensajes. De forma opcional, puedes crear un tema con un esquema para aplicar más restricciones. Para obtener más información, consulta Crea un tema o Crea y asocia un esquema cuando creas un tema.
  2. Crea un tema de Pub/Sub para capturar información sobre los registros que no se transcodifican. Este tema se denomina tema de desbordamiento. Para obtener información sobre cómo crear un tema de Pub/Sub, consulta Crea un tema.
  3. Para convertir los registros a JSON antes de enviarlos a Pub/Sub, configura el archivo de configuración JSON (opcional). Si no proporcionas un archivo de configuración, se usa la configuración JSON predeterminada.

  4. De forma opcional, los mensajes de Pub/Sub no contienen claves ni atributos de orden. Los mensajes de desbordamiento se envían al tema de desbordamiento con el sufijo _spillover. Para cambiar los valores predeterminados, puedes configurar el archivo de configuración de publicación de Pub/Sub. Por ejemplo, puedes usar la siguiente configuración:

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

    Reemplaza SPILLOVER_TOPIC_NAME por el nombre del tema de desbordamiento que creaste en el paso 2. El formato obligatorio es projects/{project}/topics/{topic}. La información sobre los mensajes que no se decodifican correctamente se guarda en este tema de desbordamiento.

  5. Para publicar registros de mainframe en Pub/Sub con el comando qsam decode, ejecuta el siguiente 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
/*

    Reemplaza lo siguiente: