Alibaba Cloud Publish
CertifiedPublish messages to an MNS queue
Alibaba Cloud Publish
Publish messages to an MNS queue
Sends one or more messages to an Alibaba Cloud Message Service (MNS) queue, in batches of 16. Messages come from an inline list or a kestra:// ION file.
type: io.kestra.plugin.alibaba.mns.PublishExamples
Publish a message to a queue
id: mns_publish
namespace: company.team
tasks:
- id: publish
type: io.kestra.plugin.alibaba.mns.Publish
accessKeyId: "{{ secret('ALIBABA_ACCESS_KEY_ID') }}"
accessKeySecret: "{{ secret('ALIBABA_ACCESS_KEY_SECRET') }}"
region: cn-hangzhou
accountId: "{{ secret('ALIBABA_ACCOUNT_ID') }}"
queue: orders
from:
- data: '{"orderId": 42}'
- data:
orderId: 43
delaySeconds: 60
Publish every row of an internal storage file
id: mns_publish_file
namespace: company.team
inputs:
- id: file
type: FILE
description: An ION file with one `data` field per row
tasks:
- id: publish
type: io.kestra.plugin.alibaba.mns.Publish
accessKeyId: "{{ secret('ALIBABA_ACCESS_KEY_ID') }}"
accessKeySecret: "{{ secret('ALIBABA_ACCESS_KEY_SECRET') }}"
region: cn-hangzhou
accountId: "{{ secret('ALIBABA_ACCOUNT_ID') }}"
queue: orders
from: "{{ inputs.file }}"
Properties
accessKeyId *string
AccessKey ID
The AccessKey ID used to authenticate against Alibaba Cloud.
accessKeySecret *string
AccessKey secret
The AccessKey secret paired with the AccessKey ID.
from *stringarray
Structured data items, either as a map, a list of map, a URI, or a JSON string.
Structured data items can be defined in the following ways:
- A single item as a map (a document).
- A list of items as a list of maps (a list of documents).
- A URI, supported schemes are
kestrafor internal storage files,filefor host local files, andnsfilefor namespace files. - A JSON String that will then be serialized either as a single item or a list of items.
io.kestra.plugin.alibaba.mns.model.Message
The message data
A string or a structured value (map, list) serialized to JSON before sending. Inline messages are rendered once by Kestra, rows read from a kestra:// file are sent as is.
Delay in seconds
How long the message stays invisible after it is sent, from 0 to 604800 seconds.
Priority
From 1 (highest) to 16 (lowest), defaults to 8.
queue *string
Queue
The name of the MNS queue.
accountId string
Account ID
The Alibaba Cloud account ID, used to derive the default endpoint https://<accountId>.mns.<region>.aliyuncs.com. Not needed when endpointOverride is set.
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150endpointOverride string
Endpoint override
Custom http or https endpoint URL. When set, it takes precedence over the endpoint derived from region.
region string
Region
The Alibaba Cloud region ID, for example cn-hangzhou. The service endpoint is derived from it unless endpointOverride is set.
securityToken string
Security token
Optional Security Token Service (STS) token, required when using temporary credentials.
Outputs
messagesCount integer
Number of messages published
Metrics
mns.publish.messages counter
messagesNumber of messages published to the MNS queue.
