Sricharan Sirpa
03/06/2024, 6:27 AMSELECT
    now() as ts,
    stringTagMap['messaging.destination.name'] as `messaging.destination.name`,
    resourceTagsMap['service.name'] as `service.name`,
    toFloat64(count()) as value
FROM
    signoz_traces.distributed_signoz_index_v2
WHERE
    (timestamp >= {{.start_datetime}} AND timestamp <= {{.end_datetime}}) 
    AND stringTagMap['messaging.system'] = 'kafka'
    AND (resourceTagsMap['service.name'] = {{.region}} AND resourceTagsMap['service.name'] LIKE '%IND%')
    AND stringTagMap['messaging.operation'] = 'publish'
    AND has(stringTagMap, 'messaging.destination.name')
    AND has(resourceTagsMap, 'service.name')
GROUP BY
    `messaging.destination.name`, `service.name`Srikanth Chekuri
03/07/2024, 1:44 AM