Otlp http log example (open-telemetry#1062)

examples/common/CMakeLists.txt

@@ -1 +1,4 @@
 add_subdirectory(foo_library)
+if(WITH_LOGS_PREVIEW)
+ add_subdirectory(logs_foo_library)
+endif()

examples/common/logs_foo_library/BUILD

@@ -0,0 +1,16 @@
+package(default_visibility = ["//visibility:public"])
+
+cc_library(
+ name = "common_logs_foo_library",
+ srcs = [
+ "foo_library.cc",
+ ],
+ hdrs = [
+ "foo_library.h",
+ ],
+ defines = ["BAZEL_BUILD"],
+ deps = [
+ "//api",
+ "//sdk:headers",
+ ],
+)

examples/common/logs_foo_library/CMakeLists.txt

@@ -0,0 +1,3 @@
+add_library(common_logs_foo_library foo_library.h foo_library.cc)
+target_link_libraries(common_logs_foo_library PUBLIC ${CMAKE_THREAD_LIBS_INIT}
+ opentelemetry_api)

examples/common/logs_foo_library/foo_library.cc

@@ -0,0 +1,38 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+#ifdef ENABLE_LOGS_PREVIEW
+# include <map>
+# include <string>
+# include "opentelemetry/logs/provider.h"
+# include "opentelemetry/sdk/version/version.h"
+# include "opentelemetry/trace/provider.h"
+
+namespace logs = opentelemetry::logs;
+namespace trace = opentelemetry::trace;
+namespace nostd = opentelemetry::nostd;
+
+namespace
+{
+nostd::shared_ptr<trace::Tracer> get_tracer()
+{
+ auto provider = trace::Provider::GetTracerProvider();
+ return provider->GetTracer("foo_library", OPENTELEMETRY_SDK_VERSION);
+}
+
+nostd::shared_ptr<logs::Logger> get_logger()
+{
+ auto provider = logs::Provider::GetLoggerProvider();
+ return provider->GetLogger("foo_library_logger");
+}
+} // namespace
+
+void foo_library()
+{
+ auto span = get_tracer()->StartSpan("span 1");
+ auto scoped_span = trace::Scope(get_tracer()->StartSpan("foo_library"));
+ auto ctx = span->GetContext();
+ auto logger = get_logger();
+ logger->Log(opentelemetry::logs::Severity::kDebug, "name", "body", {}, {}, ctx.trace_id(),
+ ctx.span_id(), ctx.trace_flags(), opentelemetry::common::SystemTimestamp());
+}
+#endif

examples/common/logs_foo_library/foo_library.h

@@ -0,0 +1,6 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+#pragma once
+
+void foo_library();

examples/otlp/BUILD

@@ -23,3 +23,17 @@ cc_binary(
  "//sdk/src/trace",
  ],
 )
+
+cc_binary(
+ name = "example_otlp_http_log",
+ srcs = [
+ "http_log_main.cc",
+ ],
+ deps = [
+ "//api",
+ "//examples/common/logs_foo_library:common_logs_foo_library",
+ "//exporters/otlp:otlp_http_exporter",
+ "//exporters/otlp:otlp_http_log_exporter",
+ "//sdk/src/trace",
+ ],
+)

examples/otlp/CMakeLists.txt

@@ -14,4 +14,15 @@ if(WITH_OTLP_HTTP)
  target_link_libraries(
  example_otlp_http ${CMAKE_THREAD_LIBS_INIT} common_foo_library
  opentelemetry_trace opentelemetry_exporter_otlp_http)
+ if(WITH_LOGS_PREVIEW)
+ add_executable(example_otlp_http_log http_log_main.cc)
+ target_link_libraries(
+ example_otlp_http_log
+ ${CMAKE_THREAD_LIBS_INIT}
+ common_logs_foo_library
+ opentelemetry_trace
+ opentelemetry_logs
+ opentelemetry_exporter_otlp_http
+ opentelemetry_exporter_otlp_http_log)
+ endif()
 endif()

examples/otlp/README.md

@@ -4,8 +4,9 @@ This is an example of how to use the [OpenTelemetry
 Protocol](https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/protocol/README.md)
 (OTLP) exporter.
 
-The application in `grpc_main.cc` initializes an `OtlpGrpcExporter` instance and
-the application in `http_main.cc` initializes an `OtlpHttpExporter` instance
+The application in `grpc_main.cc` initializes an `OtlpGrpcExporter` instance,
+the application in `http_main.cc` initializes an `OtlpHttpExporter` instance.
+The application in `http_log_main.cc` initializes an `OtlpHttpLogExporter` instance
 and they register a tracer provider from the [OpenTelemetry
 SDK](https://github.com/open-telemetry/opentelemetry-cpp). The application then
 calls a `foo_library` which has been instrumented using the [OpenTelemetry

examples/otlp/http_log_main.cc

@@ -0,0 +1,93 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+#ifdef ENABLE_LOGS_PREVIEW
+# include "opentelemetry/exporters/otlp/otlp_http_exporter.h"
+# include "opentelemetry/exporters/otlp/otlp_http_log_exporter.h"
+# include "opentelemetry/logs/provider.h"
+# include "opentelemetry/sdk/logs/logger_provider.h"
+# include "opentelemetry/sdk/logs/simple_log_processor.h"
+# include "opentelemetry/sdk/trace/simple_processor.h"
+# include "opentelemetry/sdk/trace/tracer_provider.h"
+# include "opentelemetry/trace/provider.h"
+
+# include <string>
+
+# ifdef BAZEL_BUILD
+# include "examples/common/logs_foo_library/foo_library.h"
+# else
+# include "logs_foo_library/foo_library.h"
+# endif
+
+namespace trace = opentelemetry::trace;
+namespace nostd = opentelemetry::nostd;
+namespace otlp = opentelemetry::exporter::otlp;
+namespace logs_sdk = opentelemetry::sdk::logs;
+namespace logs = opentelemetry::logs;
+namespace trace_sdk = opentelemetry::sdk::trace;
+
+namespace
+{
+
+opentelemetry::exporter::otlp::OtlpHttpExporterOptions opts;
+void InitTracer()
+{
+ // Create OTLP exporter instance
+ auto exporter = std::unique_ptr<trace_sdk::SpanExporter>(new otlp::OtlpHttpExporter(opts));
+ auto processor = std::unique_ptr<trace_sdk::SpanProcessor>(
+ new trace_sdk::SimpleSpanProcessor(std::move(exporter)));
+ auto provider =
+ nostd::shared_ptr<trace::TracerProvider>(new trace_sdk::TracerProvider(std::move(processor)));
+ // Set the global trace provider
+ trace::Provider::SetTracerProvider(provider);
+}
+
+opentelemetry::exporter::otlp::OtlpHttpLogExporterOptions logger_opts;
+void InitLogger()
+{
+ logger_opts.console_debug = true;
+ // Create OTLP exporter instance
+ auto exporter =
+ std::unique_ptr<logs_sdk::LogExporter>(new otlp::OtlpHttpLogExporter(logger_opts));
+ auto processor = std::shared_ptr<logs_sdk::LogProcessor>(
+ new logs_sdk::SimpleLogProcessor(std::move(exporter)));
+ auto sdkProvider = std::shared_ptr<logs_sdk::LoggerProvider>(new logs_sdk::LoggerProvider());
+ sdkProvider->SetProcessor(processor);
+ auto apiProvider = nostd::shared_ptr<logs::LoggerProvider>(sdkProvider);
+ auto provider = nostd::shared_ptr<logs::LoggerProvider>(apiProvider);
+ opentelemetry::logs::Provider::SetLoggerProvider(provider);
+}
+} // namespace
+
+int main(int argc, char *argv[])
+{
+ if (argc > 1)
+ {
+ opts.url = argv[1];
+ logger_opts.url = argv[1];
+ if (argc > 2)
+ {
+ std::string debug = argv[2];
+ opts.console_debug = debug != "" && debug != "0" && debug != "no";
+ }
+
+ if (argc > 3)
+ {
+ std::string binary_mode = argv[3];
+ if (binary_mode.size() >= 3 && binary_mode.substr(0, 3) == "bin")
+ {
+ opts.content_type = opentelemetry::exporter::otlp::HttpRequestContentType::kBinary;
+ logger_opts.content_type = opentelemetry::exporter::otlp::HttpRequestContentType::kBinary;
+ }
+ }
+ }
+ InitLogger();
+ InitTracer();
+ foo_library();
+}
+#else
+int main()
+{
+ return 0;
+}
+#endif