Build pipelines that ingest data from event streaming sources like RabbitMQ.
docker run --rm -it -p 15672:15672 -p 5672:5672 rabbitmq:3-management
.
(This should start the RabbitMQ server on port 5672
and a management UI on port 15672
)
pipenv install pika
+ New pipeline
, then select Streaming
.
RabbitMQ
, and paste the following:
OpenSearch
and paste the following:
host
to match your OpenSearch domain’s endpoint.index_name
to match the index you want to export data into.