Organízate con las colecciones
Guarda y clasifica el contenido según tus preferencias.
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.
Para ejecutar comandos de Pub/Sub, comprueba que has asignado el rol Publicador de Pub/Sub a tu cuenta de usuario. Para obtener información sobre cómo asignar roles a una cuenta de usuario, consulta Gestionar el acceso con IAM.
Sustituye TOPIC por el nombre del tema de Pub/Sub. El formato necesario es projects/{project}/topics/{topic}.
Publicar mensajes en un tema de Pub/Sub
Mainframe Connector te permite publicar mensajes estructurados desde un mainframe en un tema de Pub/Sub. Por ejemplo, puede usar esta función para transferir registros de Queued Sequential Access Method (QSAM) de su mainframe a BigQuery mediante Pub/Sub. Estas son algunas de las ventajas de usar este método:
Puedes transformar datos o aumentarlos con IA mediante Dataflow o mediante multihilo simultáneo (SMT) de Pub/Sub.
Puedes mover registros de un mainframe a Cloud Storage.
Puedes sincronizar las actualizaciones de aplicaciones de mainframe con sistemas basados en la nube de forma similar a la captura de datos de cambios (CDC).
Para publicar mensajes estructurados desde tu mainframe en un tema de Pub/Sub, sigue estos pasos:
Crea un tema de Pub/Sub para publicar mensajes. Si quieres, puedes crear un tema con un esquema para añadir más restricciones. Para obtener más información, consulta Crear un tema o Crear y asociar un esquema al crear un tema.
Crea un tema de Pub/Sub para registrar 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 el artículo Crear un tema.
(Opcional) Para convertir los registros a JSON antes de enviarlos a Pub/Sub, configura el archivo de configuración JSON.
Si no proporcionas ningún archivo de configuración, se usará la configuración JSON predeterminada.
(Opcional) De forma predeterminada, los mensajes de Pub/Sub no contienen claves de ordenación ni atributos. 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:
Sustituye SPILLOVER_TOPIC_NAME por el nombre del tema de desbordamiento que has creado en el paso 2. El formato necesario es projects/{project}/topics/{topic}. La información sobre los mensajes que no se decodifican correctamente se guarda en este tema de desbordamiento.
Para publicar registros de mainframe en Pub/Sub con el comando qsam decode, ejecuta el siguiente JCL:
OUTPUT: la ruta de datos
del tema de Pub/Sub que has creado en el paso 1. El formato obligatorio es pubsub:projects/{project}/topics/{topic}.
TRANSCODE-CONFIG: la ruta de datos del archivo que contiene la configuración de transcodificación. Para obtener más información sobre el formato de configuración del transcodificador, consulta Configuración del transcodificador.
JSON_CONFIGURATION: (opcional) la ruta de datos del archivo de configuración JSON. Si no proporcionas ningún archivo de configuración, se usará la configuración JSON predeterminada.
[[["Es fácil de entender","easyToUnderstand","thumb-up"],["Me ofreció una solución al problema","solvedMyProblem","thumb-up"],["Otro","otherUp","thumb-up"]],[["Es difícil de entender","hardToUnderstand","thumb-down"],["La información o el código de muestra no son correctos","incorrectInformationOrSampleCode","thumb-down"],["Me faltan las muestras o la información que necesito","missingTheInformationSamplesINeed","thumb-down"],["Problema de traducción","translationIssue","thumb-down"],["Otro","otherDown","thumb-down"]],["Última actualización: 2025-08-21 (UTC)."],[],[],null,["# Publish messages to Pub/Sub from your mainframe\n\nMainframe Connector lets you publish messages to Pub/Sub\nfrom your mainframe. You can use this feature, for example, to integrate your\nmainframe with BigQuery or Cloud Storage, augment message data with\nDataflow, or trigger Cloud Run functions.\n\nBefore you begin\n----------------\n\n- If you haven't already, then [install Mainframe Connector on your mainframe](/mainframe-connector/docs/installation).\n- To run Pub/Sub commands, verify that you assign the [Pub/Sub Publisher](/iam/docs/roles-permissions/pubsub#pubsub.publisher) role to your user account. For information about assigning roles to a user account, see [Managing access using IAM](/run/docs/securing/managing-access).\n- Set up [Application Default Credentials](/docs/authentication/provide-credentials-adc).\n\nPublish a message to a Pub/Sub topic\n------------------------------------\n\nTo publish an unstructured Pub/Sub message from your mainframe,\nuse the [`pubsub topics publish` command](/mainframe-connector/docs/api-command-reference#pubsub_topics_publish) as follows: \n\n```\n//STEP01 EXEC BQSH\n//STDIN DD *\npubsub topics publish TOPIC --data=\"Hello,World\"\n/*\n```\n\nReplace \u003cvar translate=\"no\"\u003eTOPIC\u003c/var\u003e with the name of the Pub/Sub\ntopic. The required format is `projects/{project}/topics/{topic}`.\n\nPublish messages to a Pub/Sub topic\n-----------------------------------\n\nMainframe Connector lets you publish structured messages from a\nmainframe to a Pub/Sub topic. For example, you can use this\ncapability to transfer Queued Sequential Access Method (QSAM) records from your\nmainframe to BigQuery using Pub/Sub. The following are\nsome of the advantages of using this approach:\n\n- You can transform data or augment data with AI through Dataflow or through Pub/Sub simultaneous multithreading (SMTs).\n- You can move records from a mainframe to Cloud Storage.\n- You can synchronize mainframe application updates to cloud-based systems similar to change data capture (CDC).\n\nTo publish structured messages from your mainframe to a Pub/Sub\ntopic, use the following steps:\n\n1. Create a Pub/Sub topic to publish messages. Optionally, you can create a topic with a schema for more restrictions. For more information, see [Create a topic](/pubsub/docs/create-topic) or [Create and associate a schema when you create a topic](/pubsub/docs/associate-schema-topic).\n2. Create a Pub/Sub topic to capture information about records that fail to be transcoded. This topic is called a spillover topic. For information on creating a Pub/Sub topic, see [Create a topic](/pubsub/docs/create-topic).\n3. (Optional) To convert the records to JSON before sending them to Pub/Sub, configure the [JSON configuration file](/mainframe-connector/docs/json-configuration). If you don't provide a configuration file, the default JSON configuration is used.\n4. (Optional) By default, Pub/Sub messages don't contain ordering\n keys, and attributes. Spillover messages are sent to the spillover topic\n with the `_spillover` suffix. To change the defaults, you can\n configure the [Pub/Sub publish configuration file](/mainframe-connector/docs/pubsub-publish-configuration). For example, you can use the following configuration:\n\n ```\n {\n \"spillover-configuration\": {\n \"name\": SPILLOVER_TOPIC_NAME\n }\n }\n ```\n\n Replace \u003cvar translate=\"no\"\u003eSPILLOVER_TOPIC_NAME\u003c/var\u003e with the name of the\n spillover topic you created in step 2. The required format is\n `projects/{project}/topics/{topic}`. Information about messages\n that are not decoded properly is saved to this spillover topic.\n5. To publish mainframe records to Pub/Sub using the\n [`qsam decode` command](/mainframe-connector/docs/api-command-reference#qsam_decode),\n run the following JCL:\n\n //STEP01 EXEC BQSH\n //STDIN DD *\n qsam decode \u003cvar translate=\"no\"\u003eINPUT\u003c/var\u003e \u003cvar translate=\"no\"\u003eOUTPUT\u003c/var\u003e \\\n --copybook \u003cvar translate=\"no\"\u003eCOPYBOOK\u003c/var\u003e\n --transcode-configuration \u003cvar translate=\"no\"\u003eTRANSCODE-CONFIG\u003c/var\u003e\n --output-format=JSONL\n --input-parameter=json-dialect=\u003cvar translate=\"no\"\u003eJSON_CONFIGURATION\u003c/var\u003e\n --input-parameter=pubsub-publish-configuration=\u003cvar translate=\"no\"\u003ePUBSUB_CONFIGURATION\u003c/var\u003e\n /*\n\n Replace the following:\n - \u003cvar translate=\"no\"\u003eINPUT\u003c/var\u003e: the [data path](/mainframe-connector/docs/api-command-reference#DataPath) of the QSAM file.\n - \u003cvar translate=\"no\"\u003eOUTPUT\u003c/var\u003e: the [data path](/mainframe-connector/docs/api-command-reference#DataPath) of the Pub/Sub topic you created in step 1. The required format is `pubsub:projects/{project}/topics/{topic}`.\n - \u003cvar translate=\"no\"\u003eTRANSCODE-CONFIG\u003c/var\u003e: the [data path](/mainframe-connector/docs/api-command-reference#DataPath) of the file containing the transcoding configuration. For more information on the transcoder configuration format, see [Transcoder configuration](/mainframe-connector/docs/transcoder-configuration).\n - \u003cvar translate=\"no\"\u003eJSON_CONFIGURATION\u003c/var\u003e: (optional) the [data path](/mainframe-connector/docs/api-command-reference#DataPath) of the [JSON configuration file](/mainframe-connector/docs/json-configuration). If you don't provide a configuration file, the default JSON configuration is used.\n - \u003cvar translate=\"no\"\u003ePUBSUB_CONFIGURATION\u003c/var\u003e: (optional) the [data path](/mainframe-connector/docs/api-command-reference#DataPath) of the [Pub/Sub publish configuration file](/mainframe-connector/docs/pubsub-publish-configuration). If you don't specify a configuration file, the default Pub/Sub configuration is used."]]
