Tracing with OpenTelemetry and Lightstep in Python

class SpanExporter:
    """Interface for exporting spans.
    Interface to be implemented by services that want to export recorded in
    its own format.
    To export data this MUST be registered to the :class`..Tracer` using a
    `SimpleExportSpanProcessor` or a `BatchSpanProcessor`.
    """

    def export(self, spans: typing.Sequence[Span]) -> "SpanExportResult":
        """Exports a batch of telemetry data.
        Args:
            spans: The list of `Span`s to be exported
        Returns:
            The result of the export
        """

    def shutdown(self) -> None:
        """Shuts down the exporter.
        Called when the SDK is shut down.
        """

jaeger-agent \
--reporter.grpc.host-port=ingest.lightstep.com:443 \
--reporter.grpc.tls=true \
--jaeger.tags=access_token=<YOUR ACCESS TOKEN HERE>

#!/usr/bin/env python3
import os

import flask
import requests

from opentelemetry import trace
from opentelemetry.ext import http_requests
from opentelemetry.ext.jaeger import JaegerSpanExporter
from opentelemetry.ext.wsgi import OpenTelemetryMiddleware
from opentelemetry.sdk.trace import Tracer
from opentelemetry.sdk.trace.export import BatchExportSpanProcessor

exporter = JaegerSpanExporter(
    service_name="http-server",
    agent_host_name="localhost",
    agent_port=6831,
)

trace.set_preferred_tracer_implementation(lambda T: Tracer())
tracer = trace.tracer()

span_processor = BatchExportSpanProcessor(exporter)
tracer.add_span_processor(span_processor)

http_requests.enable(tracer)
app = flask.Flask(__name__)
app.wsgi_app = OpenTelemetryMiddleware(app.wsgi_app)

@app.route("/")
def hello():
    with tracer.start_as_current_span("parent"):
        requests.get("https://www.wikipedia.org/wiki/Rabbit")
    return "hello"

if __name__ == "__main__":
    app.run(debug=True)
    span_processor.shutdown()

#!/usr/bin/env python3
import os

import requests

from opentelemetry import trace
from opentelemetry.ext import http_requests
from opentelemetry.ext.jaeger import JaegerSpanExporter
from opentelemetry.sdk.trace import Tracer
from opentelemetry.sdk.trace.export import BatchExportSpanProcessor

exporter = JaegerSpanExporter(
    service_name="http-client",
    agent_host_name="localhost",
    agent_port=6831,
)

trace.set_preferred_tracer_implementation(lambda T: Tracer())
tracer = trace.tracer()

span_processor = BatchExportSpanProcessor(exporter)
tracer.add_span_processor(span_processor)

http_requests.enable(tracer)
response = requests.get(url="http://127.0.0.1:5000/")
span_processor.shutdown()

pip install -e git+https://github.com/lightstep/opentelemetry-exporter-python

from opentelemetry.ext.lightstep import LightstepSpanExporter
exporter = LightstepSpanExporter(
    name="exporter-demo-server",
    token="<YOUR ACCESS TOKEN HERE>",
)