mirror of
https://github.com/vimagick/dockerfiles.git
synced 2025-01-06 03:54:01 +02:00
56 lines
992 B
Markdown
56 lines
992 B
Markdown
benthos
|
|
=======
|
|
|
|
|
|
|
|
[Benthos][1] is a high performance and resilient stream processor, able to
|
|
connect various sources and sinks in a range of brokering patterns and perform
|
|
hydration, enrichments, transformations and filters on payloads.
|
|
|
|
## docker-compose.yml
|
|
|
|
```yaml
|
|
version: "3.8"
|
|
services:
|
|
benthos:
|
|
image: jeffail/benthos
|
|
command: -c /etc/benthos/config.yaml
|
|
ports:
|
|
- "4195:4195"
|
|
volumes:
|
|
- ./data:/etc/benthos
|
|
restart: unless-stopped
|
|
```
|
|
|
|
## config.yaml
|
|
|
|
```yaml
|
|
input:
|
|
mqtt:
|
|
urls:
|
|
- tcp://broker.hivemq.com:1883
|
|
topics:
|
|
- easypi
|
|
|
|
pipeline:
|
|
processors:
|
|
- jq:
|
|
query: .
|
|
- http:
|
|
url: https://httpbin.org/post
|
|
|
|
output:
|
|
stdout:
|
|
codec: lines
|
|
```
|
|
|
|
## up and running
|
|
|
|
```bash
|
|
$ docker-compose up -d
|
|
$ docker-compose logs -f
|
|
$ mosquitto_pub -h broker.hivemq.com -p 1883 -t easypi -m '{"hello":"world"}'
|
|
```
|
|
|
|
[1]: https://github.com/Jeffail/benthos
|