开放遥测#
AutoGen 原生支持开放遥测。这使您能够从应用程序收集遥测数据,并将其发送到您选择的遥测后端。
当前已实现遥测的组件包括:
运行时(单线程 Agent 运行时,Worker Agent 运行时)
为应用程序添加遥测功能#
要为应用程序添加遥测功能,您需要一个 SDK 和一个导出器。如果您的应用程序已经配置了开放遥测,您可能已经拥有这些组件。
全新遥测配置#
如果您的应用程序尚未设置开放遥测,可以按照以下步骤进行配置。
pip install opentelemetry-sdk
根据您使用的开放遥测收集器,可以选择使用 gRPC 或 HTTP 协议导出遥测数据。
# 选择安装以下其中一个
pip install opentelemetry-exporter-otlp-proto-http
pip install opentelemetry-exporter-otlp-proto-grpc
接下来,我们需要获取一个追踪提供者:
from opentelemetry import trace
from opentelemetry.exporter.otlp.proto.grpc.trace_exporter import OTLPSpanExporter
from opentelemetry.sdk.resources import Resource
from opentelemetry.sdk.trace import TracerProvider
from opentelemetry.sdk.trace.export import BatchSpanProcessor
def configure_oltp_tracing(endpoint: str = None) -> trace.TracerProvider:
# 配置追踪
tracer_provider = TracerProvider(resource=Resource({"service.name": "my-service"}))
processor = BatchSpanProcessor(OTLPSpanExporter())
tracer_provider.add_span_processor(processor)
trace.set_tracer_provider(tracer_provider)
return tracer_provider
现在您可以在创建运行时传入 trace_provider:
# 单线程运行时配置
single_threaded_runtime = SingleThreadedAgentRuntime(tracer_provider=tracer_provider)
或用于 worker 运行时#
worker_runtime = GrpcWorkerAgentRuntime(tracer_provider=tracer_provider)
就这样!您的应用程序现在已通过 OpenTelemetry 实现了遥测功能。您现在可以在遥测后端查看遥测数据。
### 现有遥测配置
如果您的应用程序中已经设置了 OpenTelemetry,可以在创建运行时传入 tracer provider:
```python
from opentelemetry import trace
# 从您的应用程序获取 tracer provider
tracer_provider = trace.get_tracer_provider()
# 用于单线程运行时
single_threaded_runtime = SingleThreadedAgentRuntime(tracer_provider=tracer_provider)
# 或用于 worker 运行时
worker_runtime = GrpcWorkerAgentRuntime(tracer_provider=tracer_provider)