Components
Expanso provides 200+ components for building powerful data pipelines. Browse, search, and filter components to find exactly what you need.
Showing 202 of 202 components
amqp_0_9
Input
Connects to an AMQP (0.91) queue. AMQP is a messaging protocol used by various message brokers, including RabbitMQ.
amqp_0_9
Output
Sends messages to an AMQP (0.91) exchange. AMQP is a messaging protocol used by various message brokers, including RabbitMQ.Connects to an AMQP (0.91)...
amqp_1
Input
Reads messages from an AMQP (1.0) server.
amqp_1
Output
Sends messages to an AMQP (1.0) server.
archive
Processor
Archives all the messages of a batch into a single message according to the selected archive format.
avro
Processor
Performs Avro based operations on messages based on a schema.
awk
Processor
Executes an AWK program on messages. This processor is very powerful as it offers a range of custom functions for querying and mutating message conten...
aws_dynamodb
Output
Inserts items into or deletes items from a DynamoDB table.
aws_dynamodb_partiql
Processor
Executes a PartiQL expression against a DynamoDB table for each message.
aws_kinesis
Input
Receive messages from one or more Kinesis streams.
aws_kinesis
Output
Sends messages to a Kinesis stream.
aws_kinesis_firehose
Output
Sends messages to a Kinesis Firehose delivery stream.
aws_lambda
Processor
Invokes an AWS lambda for each message. The contents of the message is the payload of the request, and the result of the invocation will become the ne...
aws_s3
Input
Downloads objects within an Amazon S3 bucket, optionally filtered by a prefix, either by walking the items in the bucket or by streaming upload notifi...
aws_s3
Processor
Performs an S3 GetObject operation using the `bucket` + `key` provided in the config and replaces the original message parts with the content retrieve...
aws_s3
Output
Sends message parts as objects to an Amazon S3 bucket. Each object is uploaded with the path specified with the `path` field.
aws_sns
Output
Sends messages to an AWS SNS topic.
aws_sqs
Input
Consume messages from an AWS SQS URL.
aws_sqs
Output
Sends messages to an SQS queue.