Я пытаюсь прочитать данные из Event Hub в пакетном режиме, идея состоит в том, чтобы начать с определенной последовательности, прочитать партию из 10000 сообщений, проанализировать и обработать. При следующем запуске задания выберите последний порядковый номер предыдущего запуска и прочитайте следующую партию сообщений.
Мой вопрос: как мне начать чтение с определенного порядкового номера, а затем прочитать пакет из 10000 сообщений? без необходимости указывать значение EndEventPosition
Я пытался использовать счетчик предварительной выборки как 10000, но это просто позволяет заданию работать вечно
Единственный способ получить данные - это ввести номер Start seq иконечный порядковый номер = start_Seq + 10000, но я не хочу указывать конечный порядковый номер
startingEventPosition = {
"offset": last_offset,
"seqNo": last_sn,
"enqueuedTime": None,
"isInclusive": True
}
endingEventPosition = {
"offset": None,
"seqNo": last_sn+10000,
"enqueuedTime": None,
"isInclusive": True
}
receiverOptions = {
"receiverOptions":"null"
}