2 files changed, 94 insertions, 0 deletions
diff --git a/ansible/plays/otelcol-contrib.yml b/ansible/plays/otelcol-contrib.yml
new file mode 100644
index 0000000..f667337
--- /dev/null
+++ b/ansible/plays/otelcol-contrib.yml
@@ -0,0 +1,29 @@
+- hosts:
+    - coregonus
+    - hash
+    - knot
+  tasks:
+
+    # otelcol-contrib.deb needs to be installed first
+    # adduser otelcol-contrib systemd-journal
+
+    - name: /etc/otelcol-contrib/config.yaml
+      become: yes
+      template:
+        src: otelcol-contrib/config.yaml
+        dest: /etc/otelcol-contrib/config.yaml
+      notify: systemctl restart otelcol-contrib
+
+    - name: mkdir /var/lib/otelcol/file_storage
+      become: yes
+      file:
+        path: /var/lib/otelcol/file_storage
+        owner: otelcol-contrib
+      notify: systemctl restart otelcol-contrib
+
+  handlers:
+    - name: systemctl restart otelcol-contrib
+      become: yes
+      systemd:
+        service: otelcol-contrib
+        state: restarted
diff --git a/ansible/plays/templates/otelcol-contrib/config.yaml b/ansible/plays/templates/otelcol-contrib/config.yaml
new file mode 100644
index 0000000..671dbaa
--- /dev/null
+++ b/ansible/plays/templates/otelcol-contrib/config.yaml
@@ -0,0 +1,65 @@
+receivers:
+  journald:
+    priority: debug
+
+exporters:
+  debug:
+    verbosity: detailed
+
+  nop:
+
+  otlphttp/hash:
+    endpoint: https://loki.trygvis.io/otlp
+
+extensions:
+  file_storage/journald:
+
+processors:
+  batch: {}
+
+  transform/severity_parse:
+    log_statements:
+      - context: log
+        statements:
+          - set(resource.attributes["service.namespace"], "systemd")
+          - set(resource.attributes["service.name"], body["_SYSTEMD_UNIT"])
+          - set(resource.attributes["systemd_unit"], body["_SYSTEMD_UNIT"])
+          - set(resource.attributes["systemd_slice"], body["_SYSTEMD_SLICE"])
+          - set(resource.attributes["node"], body["_HOSTNAME"])
+
+          - set(severity_number, SEVERITY_NUMBER_TRACE) where body["PRIORITY"] == "7"
+          - set(severity_text, "debug") where body["PRIORITY"] == "7"
+          - set(severity_number, SEVERITY_NUMBER_DEBUG) where body["PRIORITY"] == "6"
+          - set(severity_text, "info") where body["PRIORITY"] == "6"
+          - set(severity_number, SEVERITY_NUMBER_INFO) where body["PRIORITY"] == "5"
+          - set(severity_text, "notice") where body["PRIORITY"] == "5"
+          - set(severity_number, SEVERITY_NUMBER_WARN) where body["PRIORITY"] == "4"
+          - set(severity_text, "warning") where body["PRIORITY"] == "4"
+          - set(severity_number, SEVERITY_NUMBER_ERROR) where body["PRIORITY"] == "3"
+          - set(severity_text, "err") where body["PRIORITY"] == "3"
+          - set(severity_number, SEVERITY_NUMBER_FATAL) where body["PRIORITY"] == "2"
+          - set(severity_text, "crit") where body["PRIORITY"] == "2"
+          - set(severity_number, SEVERITY_NUMBER_FATAL) where body["PRIORITY"] == "1"
+          - set(severity_text, "alert") where body["PRIORITY"] == "1"
+          - set(severity_number, SEVERITY_NUMBER_FATAL) where body["PRIORITY"] == "0"
+          - set(severity_text, "emerg") where body["PRIORITY"] == "0"
+
+          - set(body, body["MESSAGE"])
+
+service:
+#  telemetry:
+#    logs:
+#      level: debug
+  extensions:
+    - file_storage/journald
+  pipelines:
+    logs:
+      receivers:
+        - journald
+      processors: 
+        - transform/severity_parse
+        - batch
+      exporters:
+#        - debug
+#        - nop
+        - otlphttp/hash