Spaces:
Sleeping
Sleeping
File size: 1,405 Bytes
330837e |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 |
import random
import time
import os
os.environ["MONITOR_SERVICE_NAME"] = "otlp_example"
# os.environ["LOGFIRE_WRITE_TOKEN"] = ""
os.environ["ANT_OTEL_ENDPOINT"] = "https://antcollector.alipay.com/namespace/aworld/task/aworld/otlp/api/v1/metrics"
os.environ["METRICS_SYSTEM_ENABLED"] = "true"
from aworld.metrics.metric import MetricType
from aworld.metrics.context_manager import MetricContext, ApiMetricTracker
from aworld.metrics.template import MetricTemplate
MetricContext.configure(provider="otlp",
backend="antmonitor"
)
my_counter = MetricTemplate(
type=MetricType.COUNTER,
name="my_counter",
description="My custom counter",
unit="1"
)
my_gauge = MetricTemplate(
type=MetricType.GAUGE,
name="my_gauge"
)
my_histogram = MetricTemplate(
type=MetricType.HISTOGRAM,
name="my_histogram",
buckets=[2,4,6,8,10]
)
@ApiMetricTracker()
def api():
time.sleep(random.uniform(0, 1))
def custom_code():
with ApiMetricTracker("test_custom_code"):
time.sleep(random.uniform(0, 1))
if __name__ == '__main__':
while 1:
MetricContext.count(my_counter, 1, {"test_label": "b"})
MetricContext.gauge_set(my_gauge, random.randint(1, 10), {"test_label": "b"})
# MetricContext.histogram_record(my_histogram, random.randint(0, 1000))
# api()
# custom_code()
time.sleep(random.random())
|