jmrobles

<source>
  @type  http
  @id    input1
  @label @mainstream
  port  9880
  bind 0.0.0.0
  body_size_limit 32m
  keepalive_timeout 10s
</source>

jmrobles

import logging
from logging.handlers import QueueHandler, QueueListener
import queue

from pythonjsonlogger import jsonlogger
from fluent_http import FluentHttpHandler

def main():

    logger = logging.getLogger('sample')

jmrobles

import logging 

from pythonjsonlogger import jsonlogger
from fluent_http import FluentHttpHandler


def main():

    logger = logging.getLogger('sample')
    fluent_handler = FluentHttpHandler(tag="python.info")

jmrobles

import logging 
from fluent_http import FluentHttpHandler

def main():

    logger = logging.getLogger('sample')
    fluent_handler = FluentHttpHandler(tag="python.info")
    logger.addHandler(fluent_handler)
    logger.setLevel(logging.INFO)

jmrobles

<source>
  @type  forward
  @id    input1
  @label @mainstream
  port  24224
</source>
<source>
  @type http
  @id input2
  @label @mainstream

jmrobles

FROM fluent/fluentd:v1.15-debian-1
USER root
RUN gem uninstall -I elasticsearch
RUN gem install elasticsearch -v 7.17.0
RUN gem install fluent-plugin-elasticsearch --no-document --version 5.2.0
USER fluent

jmrobles

apiVersion: apps/v1
kind: Deployment
metadata:
  name: fluentd
  namespace: default
  labels:
    app: fluentd
spec:
  selector:
    matchLabels:

jmrobles

apiVersion: apps/v1
kind: Deployment
metadata:
  name: kibana
  namespace: default
  labels:
    app: kibana
spec:
  selector:
    matchLabels:

jmrobles

apiVersion: v1
kind: PersistentVolumeClaim
metadata:
  name: elastic-pvc
  namespace: default
  labels:
    app: elastic-pvc
spec:
  storageClassName: nfs-client
  accessModes:

jmrobles

import logging
from functools import wraps
from fastapi import FastAPI, Request
import time
import random

from opentelemetry.exporter.jaeger.thrift import JaegerExporter
from opentelemetry.sdk.trace.export import BatchSpanProcessor
from opentelemetry import trace
from opentelemetry.sdk.trace import TracerProvider