Запрос Kusto на время между записями по группам в одном списке результатов

У меня есть экземпляр Debezium, читающий события CDC из базы данных для нескольких разных таблиц и публикующий эти сообщения в одной и той же теме Центров событий Kafka/Azure. Масштабируемая служба использует эти сообщения и записывает инструкции отладки с отметкой времени и таблицей исходных данных.

Каждый модуль обрабатывает только одно сообщение за раз — они однопоточные. Я хочу знать, сколько времени требуется модулю для обработки каждого типа сообщений в целях оценки производительности. То есть я хочу запросить разницу во времени между каждой записью журнала «Получено», сгруппированной по модулям, в развертывании AKS потребительской службы. С помощью этого ответа я разобрался с этим для отдельных модулей, но мне бы хотелось получить представление обо всех модулях с помощью одного запроса.

Вот пример запроса и результатов Kusto для интересующих меня необработанных журналов:

ContainerLogV2 
| where TimeGenerated > ago(2h)
| where PodName startswith "<common pod prefix>"
| where LogMessage contains "received:" 
| project TimeGenerated, LogMessage, PodName

Основываясь на вопросе, указанном выше, я смог получить эти данные для одного модуля за раз с помощью следующего запроса:

ContainerLogV2
| where TimeGenerated > ago(2h)
| where PodName startswith "<common pod prefix>"
| where PodName endswith "<unique pod suffix A>"
| where LogMessage contains "received:"
| order by TimeGenerated desc
| extend prev_tg = prev(TimeGenerated)
| parse LogMessage with * "dbo." TABLE_NAME '"}' *
| project TimeGenerated, 
    // LogMessage,
    TABLE_NAME,
    // PodName,
    diff = case(true, abs(prev_tg - TimeGenerated)/1s, double(null))
| where isnotnull(diff)

Который производит такие данные, как:

Благодаря этому я могу собрать сообщения из TABLE_ONE, обработка которых займет минуту, так что это будет хорошей целью, например, для исследования производительности.

Я застрял в том, что не знаю, как правильно вычислить эту разницу при удалении фильтра <unique-pod-suffix>. Я больше не могу просто вычислить разницу во времени с предыдущей записью журнала, это должна быть разница с предыдущей записью журнала того же модуля, поскольку все модули входят в один и тот же контейнер/таблицу «ContainerLogV2». Я не знаю, как правильно выполнить эту группировку, а затем снова объединить ее в одну таблицу результатов.

Любая помощь приветствуется, спасибо!