Amazon Kinesis

This quickstart describes how to create an Amazon Kinesis connection.

Create a connection to Amazon Kinesis

To ingest data from your Amazon Kinesis stream using Upsolver, you must first create a connection that provides the appropriate credentials to access your topic.

Your connection is persistent, so you won't need to re-create it for every job. The connection is also shared with other users in your organization.

Here’s the code for creating a connection to Amazon Kinesis:

// Syntax
CREATE KINESIS CONNECTION <connection_identifier> 
    AWS_ROLE = '<role_arn>' 
    REGION = '<region>'; 

// Example
CREATE KINESIS CONNECTION my_kinesis_connection
    AWS_ROLE = 'arn:aws:iam::123456789012:role/upsolver-sqlake-role'
    REGION = 'us-east-1';

To break down exactly what’s happening, let’s go through the code. In the following line, you create an connection named my_kinesis_connection:

CREATE KINESIS CONNECTION my_kinesis_connection

Next, you identify your role within your organization's framework on AWS. Please refer to this page for more information on AWS roles.

AWS_ROLE = 'arn:aws:iam::111111111111:role/<upsolver-role-*'

For future reference, your AWS_ROLE can be copied from your AWS IAM user page.

Set the AWS region you want to use:

REGION = 'us-east-1'

After you complete this step, you should see the my_kinesis_connection connection in your navigation tree.

---

Learn more

Please see the SQL command reference for Amazon Kinesis for the full list of connection options, and examples.