liqiang
b119135836
Build latest book artifacts / build (push) Canceled after 0s
dependency resolution / resolve (3.11) (push) Canceled after 0s
dependency resolution / resolve (3.13) (push) Canceled after 0s
deploy-pages / build (push) Canceled after 0s
deploy-pages / deploy (push) Canceled after 0s
i18n consistency check / check (push) Canceled after 0s
provider adoption tests / test (chapter2/context-compression) (push) Canceled after 0s
provider adoption tests / test (chapter2/prompt-injection) (push) Canceled after 0s
provider adoption tests / test (chapter2/system-hint) (push) Canceled after 0s
provider adoption tests / test (chapter3/log-sanitization) (push) Canceled after 0s
web-search-agent tests / test (push) Canceled after 0s
web-search-agent tests / agentbook (push) Canceled after 0s
30 lines
968 B
Python
30 lines
968 B
Python
import os
|
|
import json
|
|
from aworld.logs.util import logger, trace_logger
|
|
from typing import Sequence
|
|
import aworld.trace as trace
|
|
from aworld.trace.base import Span
|
|
from aworld.trace.span_cosumer import register_span_consumer, SpanConsumer
|
|
from aworld.logs.util import logger, trace_logger
|
|
|
|
os.environ["MONITOR_SERVICE_NAME"] = "otlp_example"
|
|
|
|
|
|
@register_span_consumer({"test_param": "MockSpanConsumer111"})
|
|
class MockSpanConsumer(SpanConsumer):
|
|
|
|
def __init__(self, test_param=None):
|
|
self._test_param = test_param
|
|
|
|
def consume(self, spans: Sequence[Span]) -> None:
|
|
for span in spans:
|
|
logger.info(
|
|
f"_test_param={self._test_param}, trace_id={span.get_trace_id()}, span_id={span.get_span_id()}, attributes={span.attributes}")
|
|
|
|
|
|
def main():
|
|
with trace.span("hello") as span:
|
|
span.set_attribute("parent_test_attr", "pppppp")
|
|
logger.info("hello aworld")
|
|
trace_logger.info("trace hello aworld")
|