WIP

Author: Watson1978

example/fluentd/Dockerfile

@@ -3,8 +3,14 @@ FROM fluent/fluentd:edge-debian
 USER root
 RUN apt-get update && \
     apt-get install -y --no-install-recommends \
+    git \
     build-essential \
     make \
     gcc \
     git
-RUN gem install fluent-plugin-opentelemetry grpc
+RUN git clone https://github.com/Watson1978/fluent-plugin-opentelemetry.git && \
+    cd fluent-plugin-opentelemetry && \
+    git checkout -b metrics origin/metrics && \
+    gem build && \
+    gem install fluent-plugin-opentelemetry-*.gem
+RUN gem install grpc

example/fluentd/fluent.conf

@@ -14,6 +14,12 @@
   </http>
 </source>
 
+<source>
+  @type opentelemetry_metrics
+  tag opentelemetry.fluentd.metrics
+  emit_interval 15s
+</source>
+
 # Send traces data to jaeger directly using OpenTelemetry Protocol
 <match opentelemetry.traces>
   @type opentelemetry

lib/fluent/plugin/in_opentelemetry_metrics.rb

@@ -7,6 +7,8 @@
 require "fluent/plugin_helper/timer"
 require "fluent/version"
 
+require "json"
+
 module Fluent::Plugin
   class OpentelemetryMetricsInput < Input
     Fluent::Plugin.register_input("opentelemetry_metrics", self)
@@ -24,7 +26,7 @@ def start
 
       @metrics = Metrics.new
       timer_execute(:in_opentelemetry_metrics, @emit_interval) do
-        router.emit(@tag, Fluent::EventTime.now, { "type" => Opentelemetry::RECORD_TYPE_METRICS, "message" => @metrics.metrics_data })
+        router.emit(@tag, Fluent::EventTime.now, { "type" => Opentelemetry::RECORD_TYPE_METRICS, "message" => JSON.generate(@metrics.metrics_data) })
       end
     end