Extensión de Google Cloud Pub/Sub

Estás viendo la documentación de Apigee Edge.
Ve a la Documentación de Apigee X. información

Versión: 1.2.0

Publicar mensajes en un tema en el servicio de Google Cloud Pub/Sub

En este contenido, se proporciona referencia para configurar y usar esta extensión.

Requisitos previos

Antes de usar esta extensión desde un proxy de API, debes hacer lo siguiente:

1. Crea un tema de Cloud Pub/Sub, como se describe en la guía de inicio rápido para usar la consola.

2. Una vez que tengas el tema, otorga permiso para publicar en tu tema de Cloud Pub/Sub. Por ejemplo, puedes usar el rol roles/pubsub.publisher para publicar en temas. Para obtener más información sobre los roles de Cloud Pub/Sub, consulta Control de acceso.

3. Usar GCP Console a fin de generar una clave para la cuenta de servicio

4. Usa el contenido del archivo JSON de claves resultante cuando agregues y configures la extensión con la referencia de configuración.

Acerca de Cloud Pub/Sub

Cloud Pub/Sub proporciona mensajería asíncrona de varios a varios que separa a los remitentes de los receptores. Cloud Pub/Sub ofrece una mensajería duradera y de baja latencia que ayuda a los desarrolladores a integrar rápidamente los sistemas alojados en Google Cloud Platform y en servicios externos.

Si recién comienzas a usar Cloud Pub/Sub, revisa las guías de inicio rápido en la documentación de Cloud Pub/Sub.

Ejemplos

En los siguientes ejemplos, se muestra cómo configurar la compatibilidad con las acciones de extensión de Cloud Pub/Sub con la política ExtensionReference.

<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<ConnectorCallout async="false" continueOnError="true" enabled="true" name="Publish-Message">
    <DisplayName>Publish Message</DisplayName>
    <Connector>cloud-pub-sub-extension-example</Connector>
    <Action>publish</Action>
    <Input><![CDATA[
      {
          "message" : "My test message."
      }
    ]]></Input>
    <Output>topic.message.id</Output>
</ConnectorCallout>

<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<AssignMessage async="false" continueOnError="false" enabled="true" name="Get-Topic-Message-ID">
    <DisplayName>Get Topic Message ID</DisplayName>
    <AssignTo type="response" createNew="false"/>
    <Set>
        <Payload contentType="application/json">{topic.message.id}</Payload>
    </Set>
</AssignMessage>

{"messageId":"165918654986954"}

Acciones

publicar

Publica un mensaje en el tema especificado en la configuración de esta extensión.

<Action>publish</Action>
<Input><![CDATA[{
  "message" : "message-to-publish"
}]]></Input>

<Action>publish</Action>
<Input><![CDATA[
  {
      "message" : "My test message."
  }
]]></Input>

parámetros de solicitud

Respuesta

JSON que contiene el ID del mensaje según se publicó en el tema. Por ejemplo:

{"messageId":"165918654986954"}

Referencia de configuración

Usa la siguiente información cuando configures e implementes esta extensión para usarla en proxies de API.

Propiedades de extensión comunes

Las siguientes propiedades están presentes para cada extensión.

Propiedades de este paquete de extensión