Questions tagged [fluentd]

Fluentd is open-source and distributed data collector, which receives logs in JSON format, buffers them, and sends them to other systems like Amazon S3, MongoDB, Hadoop, Loki(Grafana system) or other Fluentds.

1336 questions
34
votes
2 answers

Fluentd vs Kafka

The use case is this: I've several java applications running which all have to interact with different (each one has a specific target) elasticsearch indices. For instance an application A uses the indices A,B,C of ElasticSearch to query and update.…
Akshay Arora
  • 729
  • 1
  • 8
  • 20
15
votes
2 answers

12Factor App: Capturing stdout/stderr logs with Fluentd

By reading the following post from 12factor I have come up with a question I'd like to check how you guys handle this. Basically, an app should write directly to stdout/stderr. Is there anyway to redirect these streams directly to fluentd (not bound…
resilva87
  • 3,325
  • 5
  • 32
  • 43
14
votes
2 answers

Fluent-bit - Splitting json log into structured fields in Elasticsearch

I am trying to find a way in Fluent-bit config to tell/enforce ES to store plain json formatted logs (the log bit below that comes from docker stdout/stderror) in structured way - please see image at the bottom for better explanation. For example,…
BentCoder
  • 12,257
  • 22
  • 93
  • 165
13
votes
3 answers

Loki config with s3

I can't get Loki to connect to AWS S3 using docker-compose. Logs are visible in Grafana but the S3 bucket remains empty. The s3 bucket is public and I have an IAM role attached to allow s3:FullAccess. I updated loki to v2.0.0 and changed the period…
markhorrocks
  • 1,199
  • 19
  • 82
  • 151
13
votes
1 answer

splitting docker stdout and stderr with fluentd fluent-plugin-rewrite-tag-filter plugin

I currently have the following config: @type rewrite_tag_filter rewriterule1 source stdout docker.nginx.stdout rewriterule2 source stderr docker.nginx.stderr but this means, that with each container I have to do…
csaboable
  • 163
  • 8
13
votes
1 answer

Modify fluentd json output

How can we easily transform with fluentd( and plugins ) something like this { "remote": "87.85.14.126", "city": "saint-hubert" } To this: { "geoip": { "remote": "87.85.14.126", "city": "saint-hubert" } } Thank you
Florent Valdelievre
  • 1,546
  • 3
  • 20
  • 32
12
votes
3 answers

How to run fluentd in docker within the internal network

I have the following configuration in my docker-compose file: fluentd: build: ./fluentd container_name: fluentd expose: - 24224 - 24224/udp depends_on: - "elasticsearch" networks: - internal public-site: …
shaft
  • 2,147
  • 2
  • 22
  • 38
12
votes
3 answers

Parsing inner JSON inside FluentD

I have some JSON being emitted from a docker container via the FluentD driver…
Dominic Bou-Samra
  • 14,799
  • 26
  • 100
  • 156
12
votes
3 answers

Docker Fluentd Logging Driver For multiline

I am trying to create a centralized logging system using fluentd for a docker environment. Currently, i able to send the docker log to fluentd using fluentd docker logging driver which is a much cleaner solution compare to reading the docker log…
cheng wee
  • 303
  • 1
  • 3
  • 11
12
votes
1 answer

Can you use environment variables in config file for fluentd

I was wondering how to use env vars in the Fluentd config, I tried: type elasticsearch logstash_format true logstash_prefix $ENV_VAR host *** port *** include_tag_key true tag_key _key but it doesn't work, any idea?
Daniel Conde Garcia
  • 265
  • 1
  • 3
  • 10
11
votes
1 answer

Use Release.Name in values.yaml in helm

I am trying to use stable/fluent-bit as a sub-chart in my chart. That chart has a value in values.yaml: backend: es: host: elasticsearch How can I set the value of backend.es.host as something like {Release.Name}-elasticsearch without making…
Nsen
  • 281
  • 1
  • 3
  • 8
11
votes
4 answers

gunicorn access log format

I'm planning to run flask through gunicorn at kubernetes. To get the logging right, I want to output all my logs in json. Currently I'm testing with minikube and https://github.com/inovex/kubernetes-logging to have fluentd collecting the logs. I…
Jens-Peter Wand
  • 111
  • 1
  • 1
  • 4
10
votes
3 answers

How to setup error reporting in Stackdriver from kubernetes pods?

I'm a bit confused at how to setup error reporting in kubernetes, so errors are visible in Google Cloud Console / Stackdriver "Error Reporting"? According to documentation https://cloud.google.com/error-reporting/docs/setting-up-on-compute-engine we…
s3ncha
  • 417
  • 1
  • 5
  • 11
9
votes
2 answers

fluentd: one source for several filters and matches

I have source: @type tail tag service path /tmp/l.log format json read_from_head true I would like to make several filters on it and match it to several outputs: @type tail tag service.pi2 …
Rudziankoŭ
  • 10,681
  • 20
  • 92
  • 192
9
votes
6 answers

FluentD log unreadable. it is excluded and would be examined next time

Facing: fluentd log unreadable. it is excluded and would be examined next time I have a simple configuration for fluentD daemon set running in kubernetes setup. Fluentd version: fluentd-0.12.43 Below is my configuration. @type tail …
Hemant Yadav
  • 307
  • 1
  • 4
  • 19
1
2 3
88 89