PutItem
yaml
type: "io.kestra.plugin.aws.dynamodb.putitem"
Examples
yaml
id: aws_dynamodb_put_item
namespace: company.team
tasks:
- id: put_item
type: io.kestra.plugin.aws.dynamodb.PutItem
accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
region: "eu-central-1"
tableName: "persons"
item:
id: 1
firstname: "John"
lastname: "Doe"
yaml
id: aws_dynamodb_put_item
namespace: company.team
tasks:
- id: put_item
type: io.kestra.plugin.aws.dynamodb.PutItem
accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
region: "eu-central-1"
tableName: "persons"
item: "{{ outputs.task_id.data | json }}"
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') }}"
Properties
tableName *Requiredstring
accessKeyId string
compatibilityMode booleanstring
endpointOverride string
forcePathStyle booleanstring
item object
region string
secretKeyId string
sessionToken string
stsEndpointOverride string
stsRoleArn string
stsRoleExternalId string
stsRoleSessionDuration string
Default
PT15M
Format
duration