add-items-to-dynamodb.yaml

id: add-items-to-dynamodb
namespace: company.team

tasks:
  - id: first_item_as_map
    type: io.kestra.plugin.aws.dynamodb.PutItem
    item:
      id: 1
      flow: "{{ flow.id }}"
      task: "{{ task.id }}"

  - id: second_item_as_json
    type: io.kestra.plugin.aws.dynamodb.PutItem
    item: |
      {
          "id": 2,
          "flow": "{{ flow.id }}",
          "task": "{{ task.id }}"
      }

pluginDefaults:
  - type: io.kestra.plugin.aws.dynamodb.PutItem
    values:
      tableName: demo
      region: "{{ secret('AWS_DEFAULT_REGION') }}"
      accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
      secretKeyId: "{{ secret('AWS_SECRET_ACCESS_KEY') }}"

extend:
  title: Add a new item to a DynamoDB table
  description: >-
    This flow adds an item to a DynamoDB table.

    The `item` property can be either a map or a JSON string.
    The `tableName` property must point to an already existing DynamoDB table.
    The `region` property must be a valid AWS region.

    It's recommended to set the `accessKeyId` and `secretKeyId` properties as
    secrets.

    This flow assumes AWS credentials stored as secrets `AWS_ACCESS_KEY_ID`,
    `AWS_SECRET_ACCESS_KEY` and `AWS_DEFAULT_REGION`.
  tags:
    - AWS
    - Ingest
  ee: false
  demo: false
  meta_description: Add items to DynamoDB tables using this flow