Huawei Trigger

Huawei Trigger
Certified
Trigger a flow when new messages arrive on a Huawei DMS for RocketMQ topic

Polls the configured topic on a fixed interval and fires one execution per batch when messages are found. Messages are stored at {{ trigger.uri }} in Kestra internal storage. For one-execution-per-message semantics use RealtimeTrigger.

yaml
type: io.kestra.plugin.huawei.dms.rocketmq.Trigger

Examples

yaml
id: dms_rocketmq_trigger
namespace: company.team

tasks:
  - id: log
    type: io.kestra.plugin.core.log.Log
    message: "Received {{ trigger.messagesCount }} messages from DMS RocketMQ"

triggers:
  - id: watch
    type: io.kestra.plugin.huawei.dms.rocketmq.Trigger
    accessKeyId: "{{ secret('HUAWEI_AK') }}"
    secretAccessKey: "{{ secret('HUAWEI_SK') }}"
    nameServerAddr: "dms-instance-id.rocketmq.eu-west-101.myhuaweicloud.com:8100"
    topic: my-topic
    groupId: kestra-trigger-group
    maxRecords: 50
    interval: PT60S

Properties

groupId *string

Consumer or producer group ID

Consumer group name for Consume/Trigger tasks; producer group name for Publish tasks.

nameServerAddr *string

Name server address

Address of the RocketMQ name server, e.g. dms-host: 8100. For DMS for RocketMQ, copy the name server address from the instance detail page in the Huawei Cloud console.

topic *string

Topic to publish to or consume from

accessKeyId string

Huawei Cloud access key ID

AK credential for the ACL authentication hook. Sensitive — always provide via {{ secret('NAME') }}.

allowConcurrent boolean

Defaultfalse

Specifies whether a trigger is allowed to start a new execution even if a previous run is still in progress.

instanceId string

DMS instance ID

Huawei Cloud DMS for RocketMQ instance ID. Required when the instance uses instance isolation. Leave empty for shared DMS instances.

interval string

DefaultPT1M

Formatduration

Polling interval

ISO-8601 duration between poll cycles, e.g. PT60S (default).

maxDuration string

Stop after this duration elapses per poll cycle

maxRecords integerstring

Stop after consuming this many messages per poll cycle

secretAccessKey string

Huawei Cloud secret access key

SK credential for the ACL authentication hook. Sensitive — always provide via {{ secret('NAME') }}.

serdeType string

DefaultSTRING

Possible Values

STRINGJSON

Message body serializer/deserializer

STRING (default) or JSON.

stopAfter array

SubTypestring

Possible Values

CREATEDSUBMITTEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDBREAKPOINTRESUBMITTED

List of execution states after which a trigger should be stopped (a.k.a. disabled).

tags string

Default*

Tag filter expression

Server-side filter applied by the broker. Use * (default) to receive all tags, or a specific tag to filter messages.

when string

Defaulttrue

A condition that determines whether the trigger should run.

A Pebble expression evaluated at trigger time. The trigger fires only when the expression evaluates to a truthy value (true, a non-empty string, a non-zero number). Use this to gate trigger execution on dynamic runtime values such as execution labels, flow variables, or environment conditions.

Outputs

messagesCount integer

Number of messages consumed from the DMS RocketMQ topic

uri string

Formaturi

URI of the ION file in Kestra internal storage containing the consumed messages