add benthos

README.md

@@ -298,6 +298,7 @@ A collection of delicious docker recipes.
 - [x] ghcr.io/linuxserver/airsonic :musical_note:
 - [x] archivebox/archivebox
 - [x] docker.bintray.io/jfrog/artifactory-oss
+- [x] jeffail/benthos
 - [x] tutum/builder
 - [x] browserless/chrome
 - [x] certbot

benthos/README.md

@@ -0,0 +1,55 @@
+benthos
+=======
+
+![](https://github.com/Jeffail/benthos/raw/master/icon.png)
+
+[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

benthos/data/config.yaml

@@ -0,0 +1,18 @@
+input:
+  mqtt:
+    urls:
+      - tcp://broker.hivemq.com:1883
+    topics:
+      - easypi
+
+pipeline:
+  processors:
+    - jq:
+        query: .
+    - http:
+        url: https://httpbin.org/post
+        verb: POST
+
+output:
+  stdout:
+    codec: lines

benthos/data/output.txt

@@ -0,0 +1,2 @@
+{"hello":"world"}
+{"foo":"bar"}

benthos/docker-compose.yml

@@ -0,0 +1,10 @@
+version: "3.8"
+services:
+  benthos:
+    image: jeffail/benthos
+    command: -c /etc/benthos/config.yaml
+    ports:
+      - "4195:4195"
+    volumes:
+      - ./data:/etc/benthos
+    restart: unless-stopped