-
Notifications
You must be signed in to change notification settings - Fork 32
fix: updated amqp instrumentation, adapted attributes and unittests #738
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: main
Are you sure you want to change the base?
Conversation
CagriYonca
commented
May 21, 2025
- Updated aioamqp instrumentation, changed spantype from sdk to amqp.
- Adapted attributes according to the backend code.
6eaddf5
to
0c61b0f
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Few comments.
Signed-off-by: Cagri Yonca <[email protected]>
@@ -26,11 +26,31 @@ async def basic_publish_with_instana( | |||
"aioamqp-publisher", span_context=parent_context | |||
) as span: | |||
try: | |||
span.set_attribute("aioamqp.exchange", argv[0]) | |||
return await wrapped(*argv, **kwargs) | |||
span.set_attribute("amqp.message", argv[0]) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I couldn't find an entry for amqp.message
attribute in the backend/ui-client code. Could you please confirm if we need this here?
If yes, can you decode()
the message from bytes
to str
and then store?