Tiện ích Google Cloud Pub/Sub

Tin nhắn văn bản

Trong ví dụ này, thao tác publish sẽ xuất bản một thông báo dưới dạng một chuỗi đơn giản đến một chủ đề được chỉ định trong cấu hình của tiện ích. Thao tác publish trả về mã nhận dạng của thông báo đã xuất bản trong chủ đề đã xuất bản và ghi thông báo đó vào biến do thẻ <Output> chỉ định:

<?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</Output>
</ConnectorCallout>

Chính sách Chỉ định thông báo sau đây sử dụng giá trị của biến lưu trữ phản hồi của tiện ích để chỉ định tải trọng phản hồi. Mã thông báo được lưu trữ trong thuộc tính messageId của biến đầu ra:

<?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.messageId}</Payload>
    </Set>
</AssignMessage>

Dữ liệu phản hồi được trả về dưới dạng JSON:

{"messageId":"165918654986954"}

Do đó, giá trị của topic.message.messageId là 165918654986954.

Thông báo JSON

Trong ví dụ này, thao tác publish sẽ phát hành một thông báo dưới dạng JSON sang một chủ đề được chỉ định trong cấu hình của tiện ích. Thao tác publish trả về mã nhận dạng của thông báo đã xuất bản trong chủ đề đã xuất bản và ghi thông báo đó vào biến do thẻ <Output> chỉ định:

<?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" : { "info" : "My test message" }
      }
    ]]></Input>
    <Output>topic.message</Output>
</ConnectorCallout>

Chính sách Chỉ định thông báo sau đây sử dụng giá trị của biến lưu trữ phản hồi của tiện ích để chỉ định tải trọng phản hồi. Mã thông báo được lưu trữ trong thuộc tính messageId của biến đầu ra:

<?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.messageId}</Payload>
    </Set>
</AssignMessage>

Dữ liệu phản hồi được trả về dưới dạng JSON:

{"messageId":"165918654986954"}

Do đó, giá trị của topic.message.messageId là 165918654986954.

Cú pháp

<Action>publish</Action>
<Input><![CDATA[{
  "message" : "message-to-publish" | JSON-structured-data,
  "customAttributes": JSON-array
}]]></Input>

Ví dụ về chuỗi

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

Ví dụ về dữ liệu có cấu trúc JSON

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

Ví dụ về thuộc tính tùy chỉnh

<Action>publish</Action>
<Input><![CDATA[
  {
      "message" : { "info" : "My test message" },
      "customAttributes": {"attr1": "foo", "attr2": "bar"}
  }
]]></Input>