Yandex Cloud Message Queue Trigger
AI-generatedSummary
Polls a specified Yandex Cloud Message Queue at configured intervals and outputs received messages as workflow trigger data.
Inputs
- Queue (required) — The URL of the Yandex Cloud Message Queue to listen to, selectable from a list or by direct URL input.
- Options — Settings such as batch size (max 10 messages per poll), whether to delete messages after processing, inclusion of message attributes, JSON parsing of message bodies, returning only message bodies, and visibility timeout (in seconds) controlling message hiding after retrieval.
- Poll Times (required) — Scheduling options defining when polling occurs, supporting fixed intervals (every minute, hour, day, week, month), custom cron expressions, or intervals specified in minutes or hours.
Output shape
a list of message objects, each containing messageId, receiptHandle, body (optionally JSON parsed or reduced to only body), MD5 hash of the body, message attributes if included, and other message attributes; returned as an array of JSON objects under the main output.
Batch size controls the maximum messages returned per poll (1-10). Messages can be automatically deleted after successful processing based on configuration. Polling uses long polling with a 20-second wait time. If no messages are received, no output is emitted for that poll cycle.
Examples
Example 1: Triggering a workflow when new messages arrive in a specific Yandex Cloud Message Queue with automatic deletion after processing and message bodies parsed as JSON.
Select the queue from the list or enter its URL, set batch size to desired number, enable 'Delete After Processing', enable 'JSON Parse Body', and configure poll times as needed.