Services includes a Message processing view that aggregates metrics for messaging operations. High cardinality occurs when temporary queues are created with unique identifiers in their names (such as amq.gen-6dggtCpu, async-job-2jrmsi5y, or orders-reply-2n68vy4g), generating thousands of distinct queue names that make aggregations unusable.
Most instrumentations keep the cardinality of messaging.destination.name low by using non-standard fields like messaging.temp.queue.hash for high-cardinality data or by setting messaging.destination.temporary. However, when instrumentation doesn't follow these practices, OpenPipeline processing rules can normalize temporary queue names into patterns or flag them as temporary.
Before implementing normalization rules, query your spans to identify messaging systems with high percentages of unique destination names.
Go to
Notebooks and select Notebooks to create a new notebook.
Select New section > DQL.
Copy and paste the following query into the edit box and select Run.
fetch spans| filter isNotNull(messaging.system) and isNotNull(messaging.destination.name)| summarize count=count(), distinctCount=countDistinct(messaging.destination.name), by:{messaging.system, messaging.destination.temporary}| fieldsAdd cardinality_ratio = toDouble(distinctCount) / toDouble(count)
Examine the results for high cardinality ratios.
Systems showing high cardinality ratios (above 0.5) without messaging.destination.temporary set indicate queues that would:
You can use OpenPipeline processing rules to normalize temporary queue names into patterns or flag them as temporary.
To create a rule
Go to
Settings and select Process and contextualize > OpenPipeline > Spans.
Go to the Pipelines tab and create a new pipeline by selecting Pipeline and entering a name (for example, Queue handling).
Choose whether to normalize temporary queue names into patterns or flag them as temporary.
On the Processing tab, select Processor and choose DQL.
To add/override the temporary queue flag, define the following new DQL processor:
Name: Temporary queue selector (or any name you like)
Matching Condition: The following matches all messaging spans that were detected as not temporary and match the specific destination pattern odaRequestQueue* that we want to override to be considered temporary.
messaging.destination.temporary == false andmatchesPhrase(messaging.destination.name, "odaRequestQueue*")
DQL processor definition: The only action to perform is to overwrite the existing value from false to true.
fieldsAdd messaging.destination.temporary = true
Select Save.
Now that we have defined and saved a processor, we can enable the processor by connecting it to OpenPipeline via a new dynamic route, so that your pipeline receives span data.
Still on the Spans page, go to the Dynamic routing tab.
Select Dynamic route.
Define the dynamic route.
odaRequestQueue.
matchesPhrase(messaging.destination.name, "odaRequestQueue*")
Select Save.
After applying these rules, queues with high cardinality will either have messaging.destination.temporary set to true or normalized names, significantly reducing metric cardinality in the message processing view. To verify this, see How to identify high cardinality above.