How to send data to AWS Kinesis
In this tutorial you will learn how to send data to AWS Kinesis
Last updated
Was this helpful?
In this tutorial you will learn how to send data to AWS Kinesis
Last updated
Was this helpful?
Benefits of the AWS Kinesis output connector:
Easily process low-power device data e.g. LoRaWAN device data in a AWS Kinesis
In this tutorial, you will learn, how to send data to AWS Kinesis. The following steps are explained in more detail:
First, you will need to set up AWS kinesis in order to successfully process data from akenza in AWS services.
Create a new AWS Kinesis stream resource, by searching for Kinesis and creating a data stream
copy the stream ARN for later use
Create a new API user by searching for IAM
create a new policy with access to the Kinesis service
Expand the tab Write and select
PutRecord
PutRecords
ListShards
Add the ARN of the newly created kinesis stream as resources
create a new user which uses access key as the credentials type and the previously created policy
In akenza, create a new Data Flow with AWS Kinesis as Output Connector. Define a Connector Name, enter the IAM user id and key as well as the Kinesis data stream ARN. Save the connector and Data Flow accordingly.
Send data to your device and execute the following command accordingly.
You should now see your base64 encoded records as well as the next shard iterator. If there is no data repeat the previous command with the next shard iterator.
Once a device is connected to the kinesis, device data can be further used on various AWS services:
Possible services are:
Real-time data stream processing
Object storage is built to retrieve any amount of data from anywhere
Run code without thinking about servers or clusters
Directly stream device data from akenza to AWS Kinesis and subsequently process it in
Sign in to the
using the Data Flow and start sending data.
In order to monitor uplinks that are sent to AWS Kinesis, you can use . To check if the uplinks arrived execute as a first step the following command and copy the return value. This value is the shard iterator used in the following commands.
