steampipe plugin install awssteampipe plugin install aws

Table: aws_pipes_pipe

Amazon EventBridge Pipes connect sources to targets. It reduces the need for specialized knowledge and integration code when developing event-driven architectures, fostering consistency across your company’s applications. To set up a pipe, you choose the source, add optional filtering, define optional enrichment, and choose the target for the event data.

Examples

Basic info

select
  name,
  arn,
  current_state,
  creation_time,
  role_arn
from
  aws_pipes_pipe;

List pipes that are not in desired state

select
  name,
  arn,
  description,
  creation_time,
  current_state,
  desired_state
from
  aws_pipes_pipe
where
  desired_state <> current_state;

Get the target parameters information for each pipe

select
  name,
  target_parameters ->> 'BatchJobParameters' as batch_job_parameters,
  target_parameters ->> 'CloudWatchLogsParameters' as cloudwatch_logs_parameters,
  target_parameters ->> 'EcsTaskParameters' as ecs_task_parameters,
  target_parameters ->> 'EventBridgeEventBusParameters' as eventbridge_event_bus_parameters,
  target_parameters ->> 'HttpParameters' as http_parameters,
  target_parameters ->> 'InputTemplate' as input_template,
  target_parameters ->> 'KinesisStreamParameters' as kinesis_stream_parameters,
  target_parameters ->> 'LambdaFunctionParameters' as lambda_function_parameters,
  target_parameters ->> 'RedshiftDataParameters' as redshift_data_parameters,
  target_parameters ->> 'SageMakerPipelineParameters' as sage_maker_pipeline_parameters,
  target_parameters ->> 'SqsQueueParameters' as sqs_queue_parameters,
  target_parameters ->> 'StepFunctionStateMachineParameters' as step_function_state_machine_parameters
from
  aws_pipes_pipe;

Get enrichment parameter details for each pipe

select
  name,
  enrichment_parameters ->> 'HttpParameters' as http_parameters,
  enrichment_parameters ->> 'InputTemplate' as input_template
from
  aws_pipes_pipe;

List pipes created within the last 30 days

select
  name,
  creation_time,
  current_state,
  desired_state,
  enrichment,
  target
from
  aws_pipes_pipe
where
  creation_time >= now() - interval '30' day;

Get IAM role details for pipes

select
  p.name,
  r.arn as role_arn,
  r.role_id,
  r.permissions_boundary_arn,
  r.role_last_used_region,
  r.inline_policies,
  r.assume_role_policy
from
  aws_pipes_pipe as p,
  aws_iam_role as r
where
  p.role_arn = r.arn;

.inspect aws_pipes_pipe

AWS Pipes Pipe

Name	Type	Description
_ctx	jsonb	Steampipe context in JSON form, e.g. connection_name.
account_id	text	The AWS Account ID in which the resource is located.
akas	jsonb	Array of globally unique identifier strings (also known as) for the resource.
arn	text	The Amazon Resource Name (ARN) of the pipe.
creation_time	timestamp with time zone	The time the pipe was created.
current_state	text	The state the pipe is in.
description	text	A description of the pipe.
desired_state	text	The state the pipe should be in.
enrichment	text	The ARN of the enrichment resource.
enrichment_parameters	jsonb	The parameters required to set up enrichment on your pipe.
last_modified_time	timestamp with time zone	When the pipe was last updated.
name	text	The name of the pipe.
partition	text	The AWS partition in which the resource is located (aws, aws-cn, or aws-us-gov).
region	text	The AWS Region in which the resource is located.
role_arn	text	The ARN of the role that allows the pipe to send data to the target.
source	text	The ARN of the source resource.
source_prefix	text	The prefix matching the pipe source.
state_reason	text	The reason the pipe is in its current state.
tags	jsonb	A map of tags for the resource.
target	text	The ARN of the target resource.
target_parameters	jsonb	The parameters required to set up a target for your pipe.
target_prefix	text	The prefix matching the pipe target.
title	text	Title of the resource.

turbot/aws