Blueprints

Add a new item to a DynamoDB table

Source

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') }}"

About this blueprint

Ingest AWS

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.

Put Item

More Related Blueprints

New to Kestra?

Use blueprints to kickstart your first workflows.

Get started with Kestra