Beacon C++ SDK¶

release_url=$(curl -fsSL -o /dev/null -w '%{url_effective}' \
  https://github.com/beacon-observability/beacon-cpp/releases/latest)
release_tag=${release_url##*/}
release_version=${release_tag#v}
release_base="https://github.com/beacon-observability/beacon-cpp/releases/download/$release_tag"
archive="beacon-cpp-$release_version-source.tar.gz"
curl -fLO "$release_base/$archive"
curl -fLO "$release_base/release-manifest.json"
curl -fLO "$release_base/SHA256SUMS"
sha256sum --check SHA256SUMS
tar -xzf "$archive"
cd "beacon-cpp-$release_version"
cmake -S . -B build -DCMAKE_BUILD_TYPE=Release -DCMAKE_CXX_STANDARD=17 \
  -DOTELCPP_WITH_STL=CXX17 -DOTELCPP_BUILD_TESTING=OFF \
  -DOTELCPP_WITH_BENCHMARK=OFF -DOTELCPP_WITH_EXAMPLES=OFF \
  -DOTELCPP_WITH_FUNC_TESTS=OFF -DOTELCPP_WITH_OTLP_HTTP=ON \
  -DOTELCPP_WITH_HTTP_CLIENT_CURL=ON \
  -DOTELCPP_PROTO_PATH="$PWD/third_party/opentelemetry-proto"
cmake --build build --parallel 3
cmake --install build --prefix "$PWD/install"
export BEACON_CPP_INSTALL="$PWD/install"

C++ 应用 → Beacon C++ SDK → DataKit OpenTelemetry 采集器 → 观测云

mkdir ../beacon-cpp-demo
cd ../beacon-cpp-demo

beacon-cpp-demo/
├── CMakeLists.txt
└── main.cc

cmake_minimum_required(VERSION 3.16)
project(beacon_cpp_demo LANGUAGES CXX)

find_package(opentelemetry-cpp CONFIG REQUIRED)

add_executable(beacon_cpp_demo main.cc)
target_compile_features(beacon_cpp_demo PRIVATE cxx_std_17)
target_link_libraries(beacon_cpp_demo PRIVATE
  opentelemetry-cpp::trace
  opentelemetry-cpp::otlp_http_exporter)

#include <array>
#include <chrono>
#include <iostream>
#include <string>
#include <thread>
#include <utility>

#include "opentelemetry/exporters/otlp/otlp_http_exporter_factory.h"
#include "opentelemetry/exporters/otlp/otlp_http_exporter_options.h"
#include "opentelemetry/sdk/resource/resource.h"
#include "opentelemetry/sdk/trace/batch_span_processor_factory.h"
#include "opentelemetry/sdk/trace/tracer_provider.h"
#include "opentelemetry/sdk/trace/tracer_provider_factory.h"

namespace otlp = opentelemetry::exporter::otlp;
namespace sdk = opentelemetry::sdk::trace;

int main(int argc, char **argv) {
  // 1. 指定接收端；使用命令行参数可覆盖默认的 DataKit 地址。
  otlp::OtlpHttpExporterOptions options;
  options.url = argc > 1 ? argv[1] : "http://127.0.0.1:9529/otel/v1/traces";
  options.content_type = otlp::HttpRequestContentType::kBinary;
  options.timeout = std::chrono::seconds(5);
  auto exporter = otlp::OtlpHttpExporterFactory::Create(options);

  // 2. 配置批量导出和服务名。整个应用复用同一个 provider。
  sdk::BatchSpanProcessorOptions batch_options;
  auto processor = sdk::BatchSpanProcessorFactory::Create(
      std::move(exporter), batch_options);
  auto resource = opentelemetry::sdk::resource::Resource::Create(
      {{"service.name", "beacon-cpp-demo"}});
  auto provider = sdk::TracerProviderFactory::Create(std::move(processor), resource);
  auto tracer = provider->GetTracer("beacon-cpp-demo");

  // 3. 用根 Span 包住一次请求，再明确指定子 Span 的父级。
  auto request = tracer->StartSpan("request");
  opentelemetry::trace::StartSpanOptions child_options;
  child_options.parent = request->GetContext();
  auto work = tracer->StartSpan("work", child_options);
  work->SetAttribute("demo.operation", "calculate");
  std::this_thread::sleep_for(std::chrono::milliseconds(20)); // 模拟业务处理
  work->End();

  std::array<char, 32> trace_id{};
  request->GetContext().trace_id().ToLowerBase16(trace_id);
  request->End();

  // 4. 先结束所有 Span，再关闭 provider，提交仍在批处理队列中的数据。
  const bool shutdown_ok = provider->Shutdown(std::chrono::seconds(5));
  std::cout << "trace_id=" << std::string(trace_id.data(), trace_id.size()) << "\n"
            << "shutdown_ok=" << (shutdown_ok ? "true" : "false") << "\n";
  return shutdown_ok ? 0 : 1;
}

cmake -S . -B build -DCMAKE_PREFIX_PATH="$BEACON_CPP_INSTALL"
cmake --build build --parallel 3
./build/beacon_cpp_demo http://127.0.0.1:9529/otel/v1/traces

trace_id=4bf92f3577b34da6a3ce929d0e0e4736
shutdown_ok=true

request
└── work    demo.operation=calculate