Halaman ini berlaku untuk Apigee dan Apigee hybrid.
Lihat dokumentasi
Apigee Edge.
Kebijakan PublishMessage memungkinkan Anda memublikasikan informasi alur proxy API ke topik Google Cloud Pub/Sub. Pub/Sub Google memungkinkan layanan berkomunikasi secara asinkron, dengan latensi yang jauh lebih rendah. Untuk mengetahui informasi selengkapnya tentang Pub/Sub, lihat Apa itu Pub/Sub?. Informasi yang ingin Anda publikasikan ke topik Pub/Sub dapat berupa teks literal atau variabel alur. Anda juga dapat menentukan kombinasi teks literal dan variabel alur dengan menggunakan template pesan.
Jika permintaan publikasi berhasil, Apigee akan menetapkan variabel alur publishmessage.message.id
ke nilai yang ditampilkan oleh server Pub/Sub. Untuk mengetahui informasi selengkapnya, lihat
Variabel alur.
Kebijakan ini adalah Kebijakan standar dan dapat di-deploy ke jenis lingkungan apa pun. Untuk mengetahui informasi tentang jenis dan ketersediaan kebijakan dengan setiap jenis lingkungan, lihat Jenis kebijakan.
Deployment autentikasi dan proxy
Untuk menjalankan kebijakan PublishMessage, Anda memerlukan token autentikasi. Namun, tidak ada elemen
<Authentication> eksplisit dalam definisi kebijakan. Anda harus men-deploy proxy API untuk menggunakan autentikasi Google, yang menambahkan token autentikasi ke permintaan di balik layar. Untuk mengetahui informasi tentang cara men-deploy proxy API yang menggunakan autentikasi Google, lihat
Langkah-langkah deployment.
Selain menggunakan autentikasi Google di proxy API, Anda harus
men-deploy proxy API dengan akun layanan yang memiliki peran dengan izin pubsub.topics.publish. Untuk mengetahui informasi selengkapnya tentang peran Identity and Access Management (IAM) untuk Pub/Sub, lihat Izin dan peran.
<PublishMessage>
Menentukan kebijakan PublishMessage.
| Nilai Default | T/A |
| Wajib? | Wajib |
| Jenis | Jenis kompleks |
| Elemen Induk | T/A |
| Elemen Turunan |
<Attributes><CloudPubSub><DisplayName><IgnoreUnresolvedVariables><Source><UseMessageAsSource> |
Tabel berikut memberikan deskripsi umum tentang elemen turunan <PublishMessage>:
| Elemen Turunan | Wajib? | Deskripsi |
|---|---|---|
<Attributes> |
Opsional | Serangkaian atribut yang akan dilampirkan ke pesan Pub/Sub. |
<CloudPubSub> |
Wajib | Elemen induk dari <Topic>. Elemen <Topic> menentukan
topik Pub/Sub tempat Anda ingin memublikasikan pesan. |
<DisplayName> |
Opsional | Nama kustom untuk kebijakan. |
<IgnoreUnresolvedVariables> |
Opsional | Menentukan apakah pemrosesan berhenti jika Apigee menemukan variabel yang belum diselesaikan. |
<Source> |
Opsional | Menentukan pesan yang akan dipublikasikan ke topik Pub/Sub. Elemen ini bersifat opsional, tetapi
Anda harus menggunakan <Source> atau <UseMessageAsSource>.
|
<UseMessageAsSource> |
Opsional | Menentukan pesan yang akan dipublikasikan ke topik Pub/Sub. Elemen ini bersifat opsional, tetapi
Anda harus menggunakan <Source> atau <UseMessageAsSource>.
|
| Elemen turunan lainnya | ||
<Topic> |
Wajib | Elemen turunan dari <CloudPubSub>. Menentukan topik Pub/Sub tempat Anda ingin
memublikasikan pesan. |
Elemen <PublishMessage> menggunakan sintaksis berikut:
Sintaksis
<PublishMessage continueOnError="[true|false]" enabled="[true|false]" name="Publish-Message-1">
<DisplayName>DISPLAY_NAME</DisplayName>
<Source>SOURCE_VALUE</Source>
<CloudPubSub>
<Topic>TOPIC_NAME</Topic>
</CloudPubSub>
<IgnoreUnresolvedVariables>[true|false]</IgnoreUnresolvedVariables>
</PublishMessage>Contoh - Sumber
Contoh berikut menunjukkan definisi kebijakan <PublishMessage>:
<PublishMessage continueOnError="false" enabled="true" name="Publish-Message-1"> <DisplayName>Publish Message-1</DisplayName> <Source>this is a message template {flow-variable1}</Source> <CloudPubSub> <Topic>projects/{flow-variable-project-id}/topics/{flow-variable-topic-name}</Topic> </CloudPubSub> <IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables> </PublishMessage>
Contoh - UseMessageAsSource
Kebijakan <PublishMessage> ini menentukan elemen UseMessageAsSource:
<PublishMessage continueOnError="false" enabled="true" name="Publish-Message-2"> <UseMessageAsSource>request</UseMessageAsSource> <CloudPubSub> <Topic>projects/{flow-variable-project-id}/topics/{flow-variable-topic-name}</Topic> </CloudPubSub> <IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables> </PublishMessage>
Contoh - Atribut
Kebijakan <PublishMessage> ini menentukan elemen Attributes:
<PublishMessage name="Publish-Message-3"> <Source>this is a message template {flow-variable1}</Source> <Attributes> <Attribute name='attr-name-0'>fixed-value</Attribute> <Attribute name='another-attribute-name'>{request.queryparam.attr1}</Attribute> <Attribute name='a-third-attribute-name'>{request.queryparam.attr2:default-value}</Attribute> </Attributes> <CloudPubSub> <Topic>projects/{flow-variable-project-id}/topics/{flow-variable-topic-name}</Topic> </CloudPubSub> <IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables> </PublishMessage>
Elemen ini memiliki atribut berikut yang umum untuk semua kebijakan:
| Atribut | Default | Wajib? | Deskripsi |
|---|---|---|---|
name |
T/A | Wajib |
Nama internal kebijakan. Nilai atribut Secara opsional, gunakan elemen |
continueOnError |
false | Opsional | Tetapkan ke false untuk menampilkan error saat kebijakan gagal. Perilaku ini wajar terjadi untuk
sebagian besar kebijakan. Tetapkan ke true agar eksekusi alur berlanjut meskipun setelah kebijakan gagal. Lihat juga:
|
enabled |
benar | Opsional | Tetapkan ke true untuk menerapkan kebijakan. Tetapkan ke false untuk menonaktifkan
kebijakan. Kebijakan tidak akan diterapkan meskipun tetap terlampir ke alur. |
async |
false | Tidak digunakan lagi | Atribut ini tidak digunakan lagi. |
Referensi elemen turunan
Bagian ini menjelaskan elemen turunan<PublishMessage>.
<Attributes>
Menentukan atribut yang akan dilampirkan ke pesan Pub/Sub.
Setiap atribut adalah pasangan nilai kunci. Nama yang terkait dengan atribut harus unik. Nilai untuk setiap parameter ditentukan secara dinamis saat runtime melalui template pesan.
| Nilai Default | T/A |
| Wajib? | Wajib |
| Jenis | String |
| Elemen Induk |
<PublishMessage> |
| Elemen Turunan | Tidak ada |
Elemen <Attributes> menggunakan sintaksis berikut:
Sintaksis
<Attributes> <Attribute name='NAME-1'>fixed-value</Attribute> <Attribute name='NAME-2'>{flow-variable}</Attribute> ... <Attribute name='NAME-N'>message template here {flow-variable:default-value}</Attribute> </Attributes>
Contoh 1
Contoh berikut menetapkan satu atribut dengan nilai tetap pada pesan saat dipublikasikan:
<PublishMessage name="PM-with-one-attribute">
<IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables>
<Source>{request.queryparam.message}</Source>
<Attributes>
<Attribute name='my-attribute-1'>fixed-value</Attribute>
</Attributes>
<CloudPubSub>
<Topic>projects/{request.queryparam.project}/topics/{request.queryparam.topic}</Topic>
</CloudPubSub>
</PublishMessage>Contoh 2
Contoh berikut menetapkan beberapa atribut pada pesan saat dipublikasikan; nilai beberapa di antaranya ditentukan secara dinamis saat runtime:
<PublishMessage name="PM-with-multiple-attributes"> <IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables> <Source>{my-assembled-message}</Source> <Attributes> <Attribute name='attr-0'>fixed-value</Attribute> <Attribute name='attr-1'>{flow-variable1}</Attribute> <Attribute name='attr-2'>fixed portion {flow-variable2:default-value}</Attribute> </Attributes> <CloudPubSub> <Topic>projects/{propertyset.settings.project}/topics/{propertyset.settings.topic}</Topic> </CloudPubSub> </PublishMessage>
<DisplayName>
Gunakan selain atribut name untuk memberi label pada kebijakan di editor proxy UI pengelolaan dengan nama yang berbeda dan lebih terdengar alami.
Elemen <DisplayName> umum untuk semua kebijakan.
| Nilai Default | T/A |
| Wajib? | Opsional. Jika Anda menghilangkan <DisplayName>, nilai atribut name kebijakan akan digunakan. |
| Jenis | String |
| Elemen Induk | <PolicyElement> |
| Elemen Turunan | Tidak ada |
Elemen <DisplayName> menggunakan sintaksis berikut:
Sintaks
<PolicyElement> <DisplayName>POLICY_DISPLAY_NAME</DisplayName> ... </PolicyElement>
Contoh
<PolicyElement> <DisplayName>My Validation Policy</DisplayName> </PolicyElement>
Elemen <DisplayName> tidak memiliki atribut atau elemen turunan.
<Source>
Menentukan pesan yang akan dipublikasikan.
Pesan dapat berupa teks literal, variabel alur, atau kombinasi keduanya dalam bentuk template pesan.
| Nilai Default | T/A |
| Wajib? | Opsional |
| Jenis | String |
| Elemen Induk |
<PublishMessage> |
| Elemen Turunan | Tidak ada |
Elemen <Source> menggunakan sintaksis berikut:
Sintaksis
<Source>SOURCE</Source>
Example-1
Contoh berikut menetapkan pesan sumber ke nilai variabel alur flow-var-1:
<Source>{flow-var-1}</Source>
Example-2
Contoh berikut menggunakan template pesan untuk memublikasikan pesan JSON dengan konten dinamis:
<PublishMessage name="PM-with-source-template"> <Source>{ "name": "value-1", "count": "{flow-variable1}", "action": "{flow-variable2}" }</Source> <Attributes> <Attribute name='content-type'>application/json</Attribute> </Attributes> <CloudPubSub> <Topic>projects/{propertyset.settings.project}/topics/{propertyset.settings.topic}</Topic> </CloudPubSub> </PublishMessage>
<CloudPubSub>
Elemen induk dari <Topic>.
Anda hanya dapat memublikasikan ke satu topik Pub/Sub. Oleh karena itu, Anda hanya dapat memiliki satu elemen <Topic> dalam elemen
<CloudPubSub>.
| Nilai Default | T/A |
| Wajib? | Wajib |
| Jenis | Jenis kompleks |
| Elemen Induk |
<PublishMessage> |
| Elemen Turunan |
<Topic> |
Elemen <CloudPubSub> menggunakan sintaksis berikut:
Sintaksis
<CloudPubSub> <Topic>TOPIC_NAME</Topic> </CloudPubSub>
Contoh
Contoh berikut menunjukkan deklarasi elemen <CloudPubSub>:
<CloudPubSub>
<Topic>projects/{my-project}/topics/{my-topic}</Topic>
</CloudPubSub><Topic>
Menentukan topik Pub/Sub tempat Anda ingin memublikasikan pesan <Source>.
Anda harus menentukan nama topik dalam format projects/project-id/topics/topic-name.
| Nilai Default | T/A |
| Wajib? | Wajib |
| Jenis | String |
| Elemen Induk |
<CloudPubSub> |
| Elemen Turunan | Tidak ada |
Elemen <Topic> menggunakan sintaksis berikut:
Sintaksis
<Topic>TOPIC_NAME</Topic>
Contoh
Contoh berikut menentukan topik Pub/Sub yang akan dipublikasikan:
<Topic>projects/project-id-marketing/topics/topic-name-test1</Topic>
Dalam contoh ini, project-id-marketing adalah Project ID Google Cloud Anda dan
topic-name-test1 adalah
topik tempat pesan harus dipublikasikan.
<UseMessageAsSource>
Menentukan pesan yang akan dipublikasikan.
Gunakan ini sebagai alternatif untuk elemen <Source>.
Nilainya harus berupa nama variabel alur yang merujuk ke pesan, seperti
request, response, atau message. Saat Anda menentukan elemen ini, kebijakan menggunakan konten pesan sebagai pesan yang akan dipublikasikan. Anda harus
menggunakan elemen ini, bukan <Source>, saat konten pesan adalah aliran oktet
yang tidak dapat direpresentasikan sebagai string, misalnya konten dari file biner.
| Nilai Default | T/A |
| Wajib? | Opsional |
| Jenis | String |
| Elemen Induk |
<PublishMessage> |
| Elemen Turunan | Tidak ada |
Elemen <UseMessageAsSource> menggunakan sintaksis berikut:
Sintaksis
<PublishMessage name="PM-with-use-message-as-source"> <UseMessageAsSource>MESSAGE_NAME</UseMessageAsSource> <Attributes> <Attribute name='attr-1'>{flowvar1}</Attribute> </Attributes> <CloudPubSub> <Topic>projects/{flowvar1}/topics/{flowvar-topic}</Topic> </CloudPubSub> </PublishMessage>
Example-1
Contoh berikut memberi tahu kebijakan untuk menggunakan konten pesan permintaan sebagai payload untuk pesan Pub/Sub:
<PublishMessage name="PM-with-use-message-as-source"> <IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables> <UseMessageAsSource>request</UseMessageAsSource> <Attributes> <Attribute name='attr-1'>{flowvar1}</Attribute> </Attributes> <CloudPubSub> <Topic>projects/{propertyset.settings.project}/topics/{propertyset.settings.topic}</Topic> </CloudPubSub> </PublishMessage>
<IgnoreUnresolvedVariables>
Menentukan apakah pemrosesan berhenti jika Apigee menemukan variabel yang belum terselesaikan.
| Nilai Default | Salah |
| Wajib? | Opsional |
| Jenis | Boolean |
| Elemen Induk |
<PublishMessage>
|
| Elemen Turunan | Tidak ada |
Tetapkan nilai ke true untuk mengabaikan variabel yang belum diselesaikan dan melanjutkan pemrosesan; jika tidak, tetapkan ke false. Nilai
defaultnya adalah false.
Menetapkan <IgnoreUnresolvedVariables> ke true berbeda dengan menetapkan continueOnError <PublishMessage> ke true. Jika Anda menetapkan continueOnError ke true, Apigee akan mengabaikan semua error, bukan
hanya error dalam variabel.
Elemen <IgnoreUnresolvedVariables> menggunakan sintaksis berikut:
Sintaksis
<IgnoreUnresolvedVariables>[true|false]</IgnoreUnresolvedVariables>
Contoh
Contoh berikut menetapkan <IgnoreUnresolvedVariables> ke true:
<IgnoreUnresolvedVariables>true</IgnoreUnresolvedVariables>
Variabel alur
Variabel alur adalah objek yang menyimpan data tertentu dan tersedia untuk Anda dalam konteks alur proxy API. Variabel ini menyimpan informasi seperti informasi payload, jalur URL, alamat IP, dan data dari eksekusi kebijakan. Untuk mengetahui informasi selengkapnya tentang variabel alur, lihat Menggunakan variabel alur.
Jika kebijakan PublishMessage berhasil memublikasikan ke topik Pub/Sub,
Apigee menetapkan variabel alur publishmessage.message.id ke
messageId yang ditampilkan oleh
server Pub/Sub. Variabel alur berjenis string, dan variabel tersedia untuk Anda
dari alur permintaan Proxy dan seterusnya. Berdasarkan persyaratan Anda, Anda dapat menggunakan variabel alur di
kebijakan hilir lainnya. Namun, jika publikasi gagal,
Apigee tidak menetapkan variabel publishmessage.message.id,
dan mengakses variabel ini akan menyebabkan error.
Untuk mengetahui informasi selengkapnya tentang berbagai jenis variabel alur, lihat Referensi variabel alur.
Kode error
This section describes the fault codes and error messages that are returned and fault variables that are set by Apigee when this policy triggers an error. This information is important to know if you are developing fault rules to handle faults. To learn more, see What you need to know about policy errors and Handling faults.
Runtime errors
These errors can occur when the policy executes.
| Fault code | HTTP status | Cause |
|---|---|---|
steps.publishmessage.PermissionDeniedError |
500 |
This error occurs when the runtime service account cannot impersonate the proxy service account or the proxy service account does not have the permission to publish to the topic. |
steps.publishmessage.ExecutionError |
500 |
This error occurs if there was an unexpected error while publishing the message to Pub/Sub. You can view the details of the error in the error message. |
steps.publishmessage.MessageVariableNotMessageType |
500 |
This error occurs if the variable name you specified in UseMessageAsSource
cannot be resolved, or is not a message type.
|
Fault variables
Whenever there are execution errors in a policy, Apigee generates error messages. You can view these error messages in the error response. Many a time, system generated error messages might not be relevant in the context of your product. You might want to customize the error messages based on the type of error to make the messages more meaningful.
To customize the error messages, you can use either fault rules or the RaiseFault policy. For
information about differences between fault rules and the RaiseFault policy, see
FaultRules vs. the RaiseFault policy.
You must check for conditions using the Condition element in both the fault rules and the RaiseFault policy.
Apigee provides fault variables unique to each policy and the values of the fault variables are set when a policy triggers runtime errors.
By using these variables, you can check for specific error conditions and take appropriate actions. For more information about checking error
conditions, see Building conditions.
| Variables | Where | Example |
|---|---|---|
fault.name |
The fault.name can match to any of the faults listed in the Runtime errors table.
The fault name is the last part of the fault code. |
fault.name Matches "UnresolvedVariable" |
publishmessage.POLICY_NAME.failed |
POLICY_NAME is the user-specified name of the policy that threw the fault. | publishmessage.publish-message-1.failed = true |