|
| 1 | +from __future__ import absolute_import |
1 | 2 | import opentracing.ext.tags as ext |
| 3 | +import instana |
2 | 4 | import opentracing |
3 | 5 | import wrapt |
4 | 6 |
|
5 | 7 |
|
6 | 8 | @wrapt.patch_function_wrapper('urllib3', 'PoolManager.urlopen') |
7 | 9 | def urlopen_with_instana(wrapped, instance, args, kwargs): |
8 | 10 | try: |
9 | | - span = opentracing.global_tracer.start_span("urllib3") |
| 11 | + span = instana.internal_tracer.start_span("urllib3") |
10 | 12 | span.set_tag(ext.HTTP_URL, args[1]) |
11 | 13 | span.set_tag(ext.HTTP_METHOD, args[0]) |
12 | 14 |
|
13 | | - opentracing.global_tracer.inject(span.context, opentracing.Format.HTTP_HEADERS, kwargs["headers"]) |
14 | | - |
| 15 | + instana.internal_tracer.inject(span.context, opentracing.Format.HTTP_HEADERS, kwargs["headers"]) |
15 | 16 | rv = wrapped(*args, **kwargs) |
| 17 | + |
16 | 18 | span.set_tag(ext.HTTP_STATUS_CODE, rv.status) |
17 | | - if 500 <= rv.status <= 511: |
| 19 | + if 500 <= rv.status <= 599: |
18 | 20 | span.set_tag("error", True) |
19 | 21 | ec = span.tags.get('ec', 0) |
20 | 22 | span.set_tag("ec", ec+1) |
21 | 23 |
|
22 | 24 | except Exception as e: |
23 | | - print("found error:", e) |
| 25 | + span.log_kv({'message': e}) |
24 | 26 | span.set_tag("error", True) |
25 | 27 | ec = span.tags.get('ec', 0) |
26 | 28 | span.set_tag("ec", ec+1) |
|
0 commit comments