How to load data to Redshift serverless from step function

Question

We have eventbridge pipe where I ingest data from Kinesis stream, Then with step function as enrichment I extract only the data I need to load then on redshift Serverless, I am not clear if using the target as redshift will work for serverless or if this can be done from the step function itself. Thanks

Accepted Answer

Hello,

Yes you can use Amazon Redshift Serverless as target for KDS. I would suggest to use Redshift streaming ingestion feature to ingest data from KDS to Redshift serverless in near real time. Redshift ingests the data from streams into a materialized view which you can control by doing manual refresh and then use the materialized view to do further transformations as needed.

You can refer to the below docs to learn more about the streaming ingestion.

https://aws.amazon.com/redshift/redshift-streaming-ingestion/
https://aws.amazon.com/blogs/big-data/real-time-analytics-with-amazon-redshift-streaming-ingestion/

Answer

Here's a concise guide to load data into Redshift Serverless from a Step Function:
* Ensure your Redshift Serverless cluster is properly configured and accessible, and define the necessary tables and schemas in Redshift Serverless to accommodate the incoming data.
* Your Step Function is triggered by an EventBridge event, which is, in turn, triggered by data ingested into Kinesis.
* A Lambda function within your Step Function extracts and enriches the data as required. 
* Your Lambda function can write the enriched data to an S3 bucket.
* You can have another step in your Step Function to trigger a Lambda function or an AWS Glue job that executes the COPY command to load data from S3 into Redshift Serverless.

This workflow can be adjusted based on your specific requirements

If this has answered your question or was helpful, accepting the answer would be greatly appreciated. Thank you!

How to load data to Redshift serverless from step function

相關內容