PutRecords

yaml
type: "io.kestra.plugin.aws.kinesis.PutRecords"

Examples

yaml
id: aws_kinesis_put_records
namespace: company.team

tasks:
  - id: put_records
    type: io.kestra.plugin.aws.kinesis.PutRecords
    accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
    secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
    region: "eu-central-1"
    streamName: "mystream"
    records:
      - data: "user sign-in event"
        explicitHashKey: "optional hash value overriding the partition key"
        partitionKey: "user1"
      - data: "user sign-out event"
        partitionKey: "user1"

yaml
id: aws_kinesis_put_records
namespace: company.team

tasks:
  - id: put_records
    type: io.kestra.plugin.aws.kinesis.PutRecords
    accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
    secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
    region: "eu-central-1"
    streamName: "mystream"
    records: kestra:///myfile.ion

Properties

records *stringarray

accessKeyId string

compatibilityMode booleanstring

endpointOverride string

failOnUnsuccessfulRecords booleanstring

Defaulttrue

forcePathStyle booleanstring

region string

secretKeyId string

sessionToken string

streamArn string

streamName string

stsEndpointOverride string

stsRoleArn string

stsRoleExternalId string

stsRoleSessionDuration string

DefaultPT15M

Formatduration

stsRoleSessionName string

Outputs

failedRecordsCount integer

Default0

recordCount integer

Default0

uri string

Formaturi

Metrics

duration timer

Unitnanoseconds

record.count counter

Unitrecords

record.failed counter

Unitrecords

record.successful counter

Unitrecords

Stream JSON and Application Events to AWS Kinesis Data Streams at Scale

Core Plugins and tasks

Tasks that provide Kestra's built-in orchestration, I/O, and observability capabilities.

CoreStorageScript

PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Database

Couchbase

Tasks that execute Couchbase N1QL queries and trigger Kestra flows from query results.

Database

PutRecords

Create automations with AWS Kinesis PutRecords

Stream JSON and Application Events to AWS Kinesis Data Streams at Scale

More Plugins in this Category

Core Plugins and tasks

PostgreSQL

Couchbase