Расширение Google Cloud Pub/Sub

Вы просматриваете документацию Apigee Edge .
Перейдите в документацию Apigee X.info

Версия: 1.2.0

Публикуйте сообщения в тему в сервисе Google Cloud Pub/Sub.

Данный материал содержит справочную информацию по настройке и использованию этого расширения.

Предварительные требования

Перед использованием этого расширения через API-прокси необходимо:

1. Создайте тему Cloud Pub/Sub, как описано в разделе «Быстрый старт: Использование консоли» .

2. После создания темы предоставьте ей разрешение на публикацию в вашу тему Cloud Pub/Sub. Например, вы можете использовать роль roles/pubsub.publisher для публикации в темы. Дополнительную информацию о ролях Cloud Pub/Sub см. в разделе «Контроль доступа» .

3. Используйте консоль GCP для генерации ключа для учетной записи службы .

4. При добавлении и настройке расширения с помощью справочника по конфигурации используйте содержимое полученного JSON-файла с ключами.

О системе Cloud Pub/Sub

Cloud Pub/Sub обеспечивает асинхронный обмен сообщениями по принципу «многие ко многим», разделяя отправителей и получателей. Cloud Pub/Sub гарантирует низкую задержку и надежную передачу сообщений, что помогает разработчикам быстро интегрировать системы, размещенные на платформе Google Cloud Platform и за ее пределами.

Если вы только начинаете работать с Cloud Pub/Sub, ознакомьтесь с краткими руководствами в документации Cloud Pub/Sub .

Образцы

Следующие примеры иллюстрируют, как настроить поддержку действий расширений Cloud Pub/Sub с помощью политики ExtensionCallout .

<?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"}

Действия

публиковать

Публикует сообщение в тему, указанную в конфигурации этого расширения.

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

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

Параметры запроса

Ответ

JSON-данные, содержащие идентификатор сообщения, опубликованного в теме. Например:

{"messageId":"165918654986954"}

Справочник по конфигурации

При настройке и развертывании этого расширения для использования в API-прокси используйте следующие параметры.

Общие свойства расширения

Следующие свойства присутствуют для каждого расширения.

Свойства для этого пакета расширений