Conector para Pub/Sub
Organiza tus páginas con colecciones
Guarda y categoriza el contenido según tus preferencias.
Es el conector de Workflows que define la función integrada que se usa para acceder a Pub/Sub dentro de un flujo de trabajo.
Explora más
Para obtener documentación en la que se incluye esta muestra de código, consulta lo siguiente:
Muestra de código
Salvo que se indique lo contrario, el contenido de esta página está sujeto a la licencia Atribución 4.0 de Creative Commons, y los ejemplos de código están sujetos a la licencia Apache 2.0. Para obtener más información, consulta las políticas del sitio de Google Developers. Java es una marca registrada de Oracle o sus afiliados.
[[["Fácil de comprender","easyToUnderstand","thumb-up"],["Resolvió mi problema","solvedMyProblem","thumb-up"],["Otro","otherUp","thumb-up"]],[["Difícil de entender","hardToUnderstand","thumb-down"],["Información o código de muestra incorrectos","incorrectInformationOrSampleCode","thumb-down"],["Faltan la información o los ejemplos que necesito","missingTheInformationSamplesINeed","thumb-down"],["Problema de traducción","translationIssue","thumb-down"],["Otro","otherDown","thumb-down"]],[],[],[],null,["# Connector for Pub/Sub\n\nWorkflows connector that defines the built-in function used to access Pub/Sub within a workflow.\n\nExplore further\n---------------\n\n\nFor detailed documentation that includes this code sample, see the following:\n\n- [Cloud Pub/Sub API Connector Overview](/workflows/docs/reference/googleapis/pubsub/Overview)\n\nCode sample\n-----------\n\n### YAML\n\n # This workflow demonstrates how to use the Cloud Pub/Sub connector:\n # Create a Pub/Sub topic and a subscription to that topic\n # Publish a message to the topic and pull the message from the subscription\n # Delete both the subscription and the topic\n # Expected output: \"SUCCESS\"\n - init:\n assign:\n - project: ${sys.get_env(\"GOOGLE_CLOUD_PROJECT_ID\")}\n - topic: \"TOPIC_ID\" # replace TOPIC_ID placeholder\n - subscription: \"SUBSCRIPTION_ID\" # replace SUBSCRIPTION_ID placeholder\n - message: {\"hello\": \"world\"}\n - base64Msg: ${base64.encode(json.encode(message))} # encodes bytes to Base64 text\n - create_topic:\n call: googleapis.pubsub.v1.projects.topics.create\n args:\n name: ${\"projects/\" + project + \"/topics/\" + topic}\n - create_subscription_to_topic:\n call: googleapis.pubsub.v1.projects.subscriptions.create\n args:\n name: ${\"projects/\" + project + \"/subscriptions/\" + subscription}\n body:\n name: ${\"projects/\" + project + \"/subscriptions/\" + subscription}\n topic: ${\"projects/\" + project + \"/topics/\" + topic}\n - publish_message_to_topic:\n call: googleapis.pubsub.v1.projects.topics.publish\n args:\n topic: ${\"projects/\" + project + \"/topics/\" + topic}\n body:\n messages:\n - data: ${base64Msg}\n - pull_message:\n call: googleapis.pubsub.v1.projects.subscriptions.pull\n args:\n subscription: ${\"projects/\" + project + \"/subscriptions/\" + subscription}\n body:\n maxMessages: 1\n result: m\n - check_message:\n switch:\n - condition: ${m.receivedMessages[0].message.data != base64Msg}\n next: failed\n - delete_subscription:\n call: googleapis.pubsub.v1.projects.subscriptions.delete\n args:\n subscription: ${\"projects/\" + project + \"/subscriptions/\" + subscription}\n - delete_topic:\n call: googleapis.pubsub.v1.projects.topics.delete\n args:\n topic: ${\"projects/\" + project + \"/topics/\" + topic}\n - the_end:\n return: \"SUCCESS\"\n - failed:\n raise: ${\"Received data:\" + m.receivedMessages[0].message.data + \" Expected data:\" + base64Msg}\n\nWhat's next\n-----------\n\n\nTo search and filter code samples for other Google Cloud products, see the\n[Google Cloud sample browser](/docs/samples?product=workflows)."]]