2016-09-12 2 views
3

У меня есть EventHub поток в качестве входных данных и Очередь служебной шины как выход.Поток аналитики возобновления поведения

В моем запросе используется TUMBLINGWINDOW для агрегирования событий для вывода в очередь из потока.

Если мне нужно приостановить Stream Analytics и возобновить его позже с момента его остановки, значит ли это, что мои окна данных будут отложены? Или он догонит события между последней остановкой и теперь в первом окне?

E.G. Я останавливаю аналитику в течение часа и возобновляю из остановленной точки, поэтому отныне она будет обрабатывать новые события через час.

или

Я останавливаюсь аналитику в течение часа и резюме с точки останова, первый выход будет содержать данные один час назад до сих пор, и новые окна будут обрабатывать новые данные в режиме реального времени.

ответ

2

Поскольку Stream Analytics продолжит считывать данные с того места, где он остановился, он просто запустит все данные, которые он может немедленно, и начнет производить данные в режиме реального времени почти сразу после того, как он закончит со всеми данными, которые пришел после паузы.

+0

Я написал приложение для быстрого тестирования, и оно согласуется с вами. Благодарю. –

2

Мне было интересно то же самое, когда я создал задачу Stream Analytics. Когда вы начинаете работу в первый раз, вы получаете только 2 варианта времени начала задания Job, Now и Custom.

Но когда вы начинаете работу после первого, вы получаете другую возможность: при последнем останове.

enter image description here

Чтобы возобновить остановленную работу без потери данных, выберите Последнюю остановилась (обратите внимание , что эта опция не доступна, если вы работаете на работу в первое время).

+0

Не верьте мне на слово, но я помню, как первый раз обрабатывал исторические данные (в зависимости от ввода, который я предполагаю). Легко протестировать с EventHubs. –

Смежные вопросы