turbot/aws_insights

Query: kinesis_streams_for_dynamodb_table

Usage

powerpipe query aws_insights.query.kinesis_streams_for_dynamodb_table

SQL

select
s.stream_arn as kinesis_stream_arn
from
aws_kinesis_stream as s,
aws_dynamodb_table as t,
jsonb_array_elements(
t.streaming_destination -> 'KinesisDataStreamDestinations'
) as d
where
d ->> 'StreamArn' = s.stream_arn
and t.arn = $1;