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.
More Related Blueprints