From fb9e19afbde175f491e846edef1449dee0e1c30b Mon Sep 17 00:00:00 2001 From: bebebeko Date: Thu, 15 Dec 2022 01:47:22 +0100 Subject: [PATCH] tmux -> fluentd -> logstash --- files/fluentd/shell.conf | 22 ++++++++++++++++++++++ files/logstash/config/pipelines.yml | 5 ++++- files/logstash/pipeline/kubernetes.conf | 3 +++ files/logstash/pipeline/shell.conf | 10 ++++++++++ 4 files changed, 39 insertions(+), 1 deletion(-) create mode 100644 files/fluentd/shell.conf create mode 100644 files/logstash/pipeline/shell.conf diff --git a/files/fluentd/shell.conf b/files/fluentd/shell.conf new file mode 100644 index 0000000..a96a499 --- /dev/null +++ b/files/fluentd/shell.conf @@ -0,0 +1,22 @@ + + @type named_pipe + path /tmp/tmux_fluentbit.fifo + tag tmux + format none + + + + @type rawtcp + #buffer_type file + #buffer_path /var/log/fluent/logcentral + + flush_mode interval + #flush_mode immediate + flush_interval 0.1 + + + name log1 + host 127.0.0.1 + port 12345 + + diff --git a/files/logstash/config/pipelines.yml b/files/logstash/config/pipelines.yml index 8b7f7fb..167cd95 100644 --- a/files/logstash/config/pipelines.yml +++ b/files/logstash/config/pipelines.yml @@ -1,4 +1,7 @@ -- pipeline.id: pipeline +- pipeline.id: kubernetes path.config: "/bitnami/logstash/pipeline/kubernetes.conf" #path.config: "/home/bebebeko/mindwm/files/logstash/pipeline/kubernetes.conf" pipeline.ecs_compatibility: disabled + +- pipeline.id: shell + path.config: "/bitnami/logstash/pipeline/shell.conf" diff --git a/files/logstash/pipeline/kubernetes.conf b/files/logstash/pipeline/kubernetes.conf index 521bdfb..89be8fa 100644 --- a/files/logstash/pipeline/kubernetes.conf +++ b/files/logstash/pipeline/kubernetes.conf @@ -5,6 +5,9 @@ input { codec => json } } + + + filter { if ! [kubernetes][namespace_name] { drop {} } diff --git a/files/logstash/pipeline/shell.conf b/files/logstash/pipeline/shell.conf new file mode 100644 index 0000000..b2dea9b --- /dev/null +++ b/files/logstash/pipeline/shell.conf @@ -0,0 +1,10 @@ +input { + tcp { + port => 12345 + codec => json + } +} +output { + stdout { + } +}