Чтение данных из концентратора событий в пакетном режиме с партией 10000 с указанием определенного порядкового номера - PullRequest
0 голосов
/ 10 октября 2019

Я пытаюсь прочитать данные из 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"
}
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...