Skip to main content

RabbitMQ

Availability:
Not available Airbyte CloudAvailable Airbyte OSSAvailable PyAirbyte
Support Level:
Marketplace
Connector Version:
0.1.28(Last updated 6 hours ago)
CDK Version:
0.78.4
Sync Success Rate:
Usage Rate:

Overview​

The RabbitMQ destination allows you to send/stream data to a RabbitMQ routing key. RabbitMQ is one of the most popular open source message brokers.

Sync overview​

Output schema​

Each stream will be output a RabbitMQ message with properties. The message properties will be

  • content_type: set as application/json
  • headers: message headers, which include:
    • stream: the name of stream where the data is coming from
    • namespace: namespace if available from the stream
    • emitted_at: timestamp the AirbyteRecord was emitted at.

The AirbyteRecord data will be serialized as JSON and set as the RabbitMQ message body.

Features​

FeatureSupported?(Yes/No)Notes
Full Refresh SyncYes
Incremental - Append SyncYes
Incremental - Append + DedupedNo
NamespacesYes

Getting started​

Requirements​

To use the RabbitMQ destination, you'll need:

  • A RabbitMQ host and credentials (username/password) to publish messages, if required.
  • A RabbitMQ routing key.
  • RabbitMQ exchange is optional. If specified, a binding between exchange and routing key is required.
  • RabbitMQ port is optional (it defaults to 5672).
  • RabbitMQ virtual host is also optional.

Changelog​

Expand to review
VersionDatePull RequestSubject
0.1.282024-12-2150180Update dependencies
0.1.272024-12-1449305Update dependencies
0.1.262024-11-2548642Update dependencies
0.1.252024-10-2947101Update dependencies
0.1.242024-10-1246859Update dependencies
0.1.232024-10-0546437Update dependencies
0.1.222024-09-2846139Update dependencies
0.1.212024-09-2145814Update dependencies
0.1.202024-09-1445293Update dependencies
0.1.192024-08-3144988Update dependencies
0.1.182024-08-2444726Update dependencies
0.1.172024-08-2244530Update test dependencies
0.1.162024-08-1744336Update dependencies
0.1.152024-08-1043622Update dependencies
0.1.142024-08-0343078Update dependencies
0.1.132024-07-2742759Update dependencies
0.1.122024-07-2042222Update dependencies
0.1.112024-07-1341689Update dependencies
0.1.102024-07-1041279Update dependencies
0.1.92024-07-0640991Update dependencies
0.1.82024-06-2740215Replaced deprecated AirbyteLogger with logging.Logger
0.1.72024-06-2540348Update dependencies
0.1.62024-06-2240101Update dependencies
0.1.52024-06-0639300[autopull] Upgrade base image to v1.2.2
0.1.42024-05-2138532[autopull] base image + poetry + up_to_date
0.1.32024-04-02#36749Un-archive connector (again)
0.1.22024-03-05#35838Un-archive connector
0.1.12022-09-0916528Marked password field in spec as airbyte_secret
0.1.0October 29, 2021#7560Initial release
Was this page helpful?