PutRecords

id: dis_put_records
namespace: company.team

tasks:
  - id: put_records
    type: io.kestra.plugin.huawei.dis.PutRecords
    accessKeyId: "{{ secret('HUAWEI_AK') }}"
    secretAccessKey: "{{ secret('HUAWEI_SK') }}"
    region: eu-west-101
    streamName: my-stream
    from:
      - data: "user sign-in event"
        partitionKey: "user-1"
      - data: "user sign-out event"
        partitionKey: "user-1"

id: dis_put_records_json
namespace: company.team

inputs:
  - id: dataFile
    type: FILE

tasks:
  - id: put_records
    type: io.kestra.plugin.huawei.dis.PutRecords
    accessKeyId: "{{ secret('HUAWEI_AK') }}"
    secretAccessKey: "{{ secret('HUAWEI_SK') }}"
    region: eu-west-101
    streamName: my-stream
    serdeType: JSON
    from: "{{ inputs.dataFile }}"