Skip to content

Commit

Permalink
Zipkin: Fix OTLP events to Zipkin annotations translation (#1161)
Browse files Browse the repository at this point in the history
  • Loading branch information
owais authored Sep 25, 2020
1 parent 872975b commit b255940
Show file tree
Hide file tree
Showing 3 changed files with 27 additions and 13 deletions.
1 change: 1 addition & 0 deletions exporter/opentelemetry-exporter-zipkin/CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@

- Zipkin exporter now accepts a ``max_tag_value_length`` attribute to customize the
maximum allowed size a tag value can have. ([#1151](https://github.com/open-telemetry/opentelemetry-python/pull/1151))
- Fixed OTLP events to Zipkin annotations translation. ([#1161](https://github.com/open-telemetry/opentelemetry-python/pull/1161))

## Version 0.13b0

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -237,20 +237,25 @@ def _extract_tags_from_span(self, span: Span):
tags.update(self._extract_tags_from_dict(span.resource.attributes))
return tags

def _extract_annotations_from_events(
self, events
): # pylint: disable=R0201
return (
[
def _extract_annotations_from_events(self, events):
if not events:
return None

annotations = []
for event in events:
attrs = {}
for key, value in event.attributes.items():
if isinstance(value, str):
value = value[: self.max_tag_value_length]
attrs[key] = value

annotations.append(
{
"timestamp": _nsec_to_usec_round(e.timestamp),
"value": e.name,
"timestamp": _nsec_to_usec_round(event.timestamp),
"value": json.dumps({event.name: attrs}),
}
for e in events
]
if events
else None
)
)
return annotations


def _nsec_to_usec_round(nsec):
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -223,7 +223,15 @@ def test_export(self):
"annotations": [
{
"timestamp": event_timestamp // 10 ** 3,
"value": "event0",
"value": json.dumps(
{
"event0": {
"annotation_bool": True,
"annotation_string": "annotation_test",
"key_float": 0.3,
}
}
),
}
],
"debug": True,
Expand Down

0 comments on commit b255940

Please sign in to comment.