powerful-pipes-watch-bus 1.0.3

Multi broker watcher tool that connect them with UNIX pipes. BUS Message watcher for OpenAPI Generator Project

---

Powerful Pipes Watcher - Multi-broker watcher tool with the power of UNIX Pipes

---

Index

• Install
• Quick Start
  • WatchBus
  • SendBus
• Supported brokers
  • Redis examples
• Authors
• License
• Contributions
• Acknowledgements

In a nutshell Powerful Pipes Watcher is a multi broker watcher tool that connect them with UNIX pipes.

Install

> pip install powerful-pipes-watch-bus 

Quick Start

WatchBus

Powerful Pipes Watcher read from a broker queue and re-send received data to the UNIX pipeline.

Example

> watch-bus -c redis:// -q my-queue 

Above command will connect to the localhost Redis at default port, at database number 1, and will listen for my-queue queue.

Example with multiple queues

> watch-bus -c redis:// -q my-queue -q second-queue 

With this command watch-bus will listen from two queues events.

SendBus

Powerful Pipes SendBus read from stdin and re-send received JSON data to the Broker queue(s).

Example

> cat data.json | send-bus -c redis:// -q my-queue 

Above command will connect to the localhost Redis at default port, at database number 1, and will listen for my-queue queue.

Example with multiple queues

> cat data.json | send-bus -c redis:// -q my-queue -q second-queue 

With this command sendBus will send data to two broker queues.

Supported brokers

Currently, supported brokers are:

• Redis

We'll be happy if you want to contribute adding new brokers! :)

Redis examples

Bus connections for Redis should look like:

redis://[[user]:[password]@][host][:port][/db=INTEGER]

Default values:

• user: Null
• password: Null
• Host: 127.0.0.1
• port: 6379
• db: 1

Authors

Powerful Pipes was made by 42Crunch Research Team:

• jc42
• cr0hn

License

Powerful Pipes is Open Source and available under the AGPLv3+.

Contributions

Contributions are very welcome. See CONTRIBUTING.md or skim existing tickets to see where you could help out.

Acknowledgements

Project logo thanks to Camera control vector created by upklyak.