Metadata-Version: 2.3
Name: arize-phoenix-otel
Version: 0.2.0
Summary: LLM Observability
Project-URL: Documentation, https://docs.arize.com/phoenix/
Project-URL: Issues, https://github.com/Arize-ai/phoenix/issues
Project-URL: Source, https://github.com/Arize-ai/phoenix
Author-email: Arize AI <phoenix-devs@arize.com>
License: Elastic-2.0
License-File: IP_NOTICE
License-File: LICENSE
Keywords: Explainability,Monitoring,Observability
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Requires-Python: <3.13,>=3.8
Requires-Dist: opentelemetry-exporter-otlp
Requires-Dist: opentelemetry-proto>=1.12.0
Requires-Dist: opentelemetry-sdk
Requires-Dist: opentelemetry-semantic-conventions
Requires-Dist: typing-extensions<5,>=4.5
Provides-Extra: test
Requires-Dist: mypy; extra == 'test'
Requires-Dist: pytest-asyncio; extra == 'test'
Requires-Dist: pytest==7.4.4; extra == 'test'
Description-Content-Type: text/markdown

# arize-phoenix-otel

Provides a lightweight wrapper around OpenTelemetry primitives with Phoenix-aware defaults.

These defaults are aware of the `PHOENIX_COLLECTOR_ENDPOINT`, `PHOENIX_PROJECT_NAME`, and
``PHOENIX_CLIENT_HEADERS` environment variables.

# Examples

The `phoenix.otel` module provides a high-level `register` function to configure OpenTelemetry
tracing by setting a global `TracerProvider`. The register function can also configure headers
and whether or not to process spans one by one or by batch.

```
from phoenix.otel import register

tracer_provider = register(endpoint="http://localhost:6006/v1/traces", project_name="test")
```

For more granular tracing configuration, these wrappers can be used as drop-in replacements for
OTel primitives:

```
from opentelemetry import trace as trace_api
from phoenix.otel import HTTPSpanExporter, TracerProvider, SimpleSpanProcessor

tracer_provider = TracerProvider()
span_exporter = HTTPSpanExporter(endpoint="http://localhost:6006/v1/traces")
span_processor = SimpleSpanProcessor(exporter=span_exporter)
tracer_provider.add_span_processor(span_processor)
trace_api.set_tracer_provider(tracer_provider)
```

Wrappers have Phoenix-aware defaults to greatly simplify the OTel configuration process.

```
# export PHOENIX_COLLECTOR_ENDPOINT=http://localhost:6006/v1/traces
from opentelemetry import trace as trace_api
from phoenix.otel import TracerProvider

tracer_provider = TracerProvider()
trace_api.set_tracer_provider(tracer_provider)
```

Phoenix supports sending traces via either an HTTP or gRPC protocol, if possible, the exporter
will be inferred from the endpoint URL. In the following example, tracing is configured to
export traces via the gRPC protocol based on the `PHOENIX_COLLECTOR_ENDPOINT` URL.

```
# export PHOENIX_COLLECTOR_ENDPOINT=http://localhost:4317
from opentelemetry import trace as trace_api
from phoenix.otel import TracerProvider

tracer_provider = TracerProvider()
trace_api.set_tracer_provider(tracer_provider)
```

The collector endpoint can be passed directly to the tracer provider.

```
from opentelemetry import trace as trace_api
from phoenix.otel import TracerProvider

tracer_provider = TracerProvider(endpoint="http://localhost:6006/v1/traces")
trace_api.set_tracer_provider(tracer_provider)
```

Users can gradually add OTel components as desired:

## Adding resources
```
# export PHOENIX_COLLECTOR_ENDPOINT=http://localhost:4317
from opentelemetry import trace as trace_api
from phoenix.otel import Resource, PROJECT_NAME, TracerProvider

tracer_provider = TracerProvider(resource=Resource({PROJECT_NAME: "my-project"}))
trace_api.set_tracer_provider(tracer_provider)
```

## Using a BatchSpanProcessor
```
# export PHOENIX_COLLECTOR_ENDPOINT=http://localhost:4317
from opentelemetry import trace as trace_api
from phoenix.otel import TracerProvider, BatchSpanProcessor

tracer_provider = TracerProvider()
batch_processor = BatchSpanProcessor()
tracer_provider.add_span_processor(batch_processor)
```
