How to use the Huawei Cloud plugin

Tasks and triggers for Huawei Cloud services, spanning object storage, identity and access management, messaging, data integration, monitoring, serverless functions, CLI access, and notifications. See the full list below.

Services

• OBS (io.kestra.plugin.huawei.obs): upload, download, list, copy, delete, batch-delete, create and delete buckets, and trigger flows on new objects.
• IAM (io.kestra.plugin.huawei.iam): exchange long-lived credentials for short-lived STS credentials.
• DMS for Kafka (io.kestra.plugin.huawei.dms.kafka): produce, consume, and trigger on messages using the Apache Kafka protocol.
• DMS for RocketMQ (io.kestra.plugin.huawei.dms.rocketmq): publish, consume, and trigger on messages using the Apache RocketMQ protocol.
• DataArts Studio (io.kestra.plugin.huawei.dataarts): start, monitor, and stop DataArts Factory batch job runs.
• CES (io.kestra.plugin.huawei.ces): push custom metrics, query metric statistics, and trigger flows on metric datapoints.
• FunctionGraph (io.kestra.plugin.huawei.functiongraph): synchronously invoke a FunctionGraph function.
• KooCLI (io.kestra.plugin.huawei.koocli): run arbitrary Huawei Cloud CLI (hcloud) commands in a container.
• SMN (io.kestra.plugin.huawei.smn): publish notification messages to a topic.
• DLI (io.kestra.plugin.huawei.dli): run SQL queries against data in OBS or federated sources, the Huawei equivalent of AWS Athena.
• DIS (io.kestra.plugin.huawei.dis): write and consume records on a data stream, and trigger flows on new records, the Huawei equivalent of AWS Kinesis Data Streams.
• GeminiDB for NoSQL (io.kestra.plugin.huawei.geminidb): put, get, delete, query, and scan items against a GeminiDB instance's DynamoDB-Compatible data-plane API.
• SWR (io.kestra.plugin.huawei.swr): fetch a short-lived Docker/OCI registry auth token, the Huawei equivalent of AWS ECR's GetAuthToken.

Authentication

Most tasks authenticate with an access key and secret key. Provide them via Kestra secrets rather than inline values. When using temporary credentials, also supply the security token.

OBS tasks can obtain short-lived credentials automatically through the temporaryCredentials block, set once via plugin defaults:

pluginDefaults: 
  - type: io.kestra.plugin.huawei.obs
    values: 
      region: eu-west-101
      accessKeyId: "{{ secret('HUAWEI_AK') }}"
      secretAccessKey: "{{ secret('HUAWEI_SK') }}"

Region

All tasks require a region (for example eu-west-101). Endpoints are derived from the region unless an explicit endpoint override is set.

Exception: GeminiDB. GeminiDB for NoSQL routes by a mandatory, per-instance endpoint connection address instead — there is no region-derived host. Its region is used only for AWS SigV4 request signing and has no effect on routing; see the GeminiDB plugin doc for details.