| Step Details | |
| Introduced in Version | 4.0.0 |
| Last Modified in Version | 8.9.0 |
| Location | Integration > Kinesis > Put Record Step |
The Put Record step allows individual messages to be added to an AWS Kinesis data stream.
Prerequisites
- This step requires the Amazon AWS Module to be installed before it will be available in the toolbox, and an active AWS account. The Amazon WebServices Settings must also be configured.
- For v9 users, a dependency must be created after installing the module in order for the the steps to be properly used.
Properties
Inputs
| Property | Description | Data Type |
|---|---|---|
| Data | List of Byte Data that will be passed as a record to the stream. | List of Byte |
| Hash Key | Optional string representing the hash key. | String |
| Partition Key | A Unicode string representing the partition key. This is used to group data by shard within a stream and can be a maximum of 256 characters. | String |
| Region | The region the data stream resides in. This can be found in the ARN for the data stream. | AmazonAWSRegion |
| Sequence Number | Optional string used for the sequence number. The sequence number is unique for each partition key within a shard, and will increase each time the partition key is used. | String |
| Stream Name | The Name of the data stream. | String |
Outputs
| Property | Description | Data Type | |
|---|---|---|---|
| Done | |||
| Output | Outputs shared resulting shard Id | String | |
Example Inputs and Outputs
| Data | Partition Key | Region | Stream Name | Output |
|---|---|---|---|---|
| SGVsbG8slFRoaXMgaXMgYSB0ZXN0IHN0cmluZw | 123456 | us-east-1 | Testing | shardid-000000000002 |
Common Errors
The security Token Included in the Request is Invalid
If the token inputted is expired or not declared, the step will cause an error.
To correct this, ensure you are using a token that is active.
Exception Message:
DecisionsFramework.Design.Flow.ErrorRunningFlowStep: Error running step Put Record Step 1[PutRecordStep] in flow [Dynamo Steps Flow]: Exception invoking method PutRecordStep on class KinesisSteps
---> DecisionsFramework.LoggedException: Exception invoking method PutRecordStep on class KinesisSteps
---> Amazon.Kinesis.AmazonKinesisException: The security token included in the request is invalid.
---> Amazon.Runtime.Internal.HttpErrorResponseException: Exception of type 'Amazon.Runtime.Internal.HttpErrorResponseException' was thrown. at Amazon.Runtime.HttpWebRequestMessage.ProcessHttpResponseMessage(HttpResponseMessage responseMessage)
at Amazon.Runtime.HttpWebRequestMessage.GetResponseAsync(CancellationToken cancellationToken)
at Amazon.Runtime.Internal.HttpHandler`1.InvokeAsync[T](IExecutionContext executionContext)
at Amazon.Runtime.Internal.Unmarshaller.InvokeAsync[T](IExecutionContext executionContext)
at Amazon.Runtime.Internal.ErrorHandler.InvokeAsync[T](IExecutionContext executionContext)
--- End of inner exception stack trace ---Related Information
Related Article: