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