amqp icon
DeclareExchange icon
CreateQueue icon
QueueBind icon
Log icon
Fail icon
Request icon
Publish icon
RealtimeTrigger icon

Consume RabbitMQ orders with dead letter queue handling

Consume RabbitMQ messages in real time with Kestra, validate and forward orders to an API, and automatically dead letter failed or invalid messages.

Categories
Data

More Data Blueprints

AI-Powered Inventory Demand Forecasting, Auto-Generate Purchase Orders with OpenAI

Forecast 7-day demand with OpenAI GPT-4o, auto-generate purchase orders for stockout-risk SKUs, and log them to PostgreSQL every 6 hours.

Parallel icon
Request icon
ChatCompletion icon
Script icon
If icon
ForEach icon
+3
AI Business Data
Trigger an Airflow DAG

Trigger an Apache Airflow DAG from Kestra and wait for it to finish.

TriggerDagRun icon
Data
Sync Postgres records to Algolia index

Incrementally push freshly updated Postgres rows into an Algolia search index every five minutes.

Trigger icon
ForEach icon
Index icon
Query icon
postgresql icon
Business Data
See How

New to Kestra?

Use blueprints to kickstart your first workflows.

Get Started