Примечание.
Для доступа к этой странице требуется авторизация. Вы можете попробовать войти или изменить каталоги.
Для доступа к этой странице требуется авторизация. Вы можете попробовать изменить каталоги.
Примечание.
Расширенные возможности включены по умолчанию при создании потоков событий. Если у вас есть потоки событий, созданные с помощью стандартных возможностей, эти потоки событий будут продолжать работать. Вы по-прежнему можете изменять и использовать их как обычно. Рекомендуется создать новый поток событий для замены стандартных потоков событий, чтобы воспользоваться дополнительными возможностями и преимуществами расширенных потоков событий.
В Eventstream функции Пауза и Возобновление (то есть Деактивация и Активация) предоставляют полный контроль над вашими потоками данных, позволяя приостанавливать потоковую передачу данных из различных источников и назначений в Eventstream. Затем вы можете легко возобновить потоковую передачу данных из приостановленного времени или настраиваемого времени, гарантируя отсутствие потери данных.
- Активировать/Деактивировать все: быстро приостановите и возобновите весь поток данных, поступающих и уходящих из Eventstream, с помощью опций "Активировать все" и "Деактивировать все" в строке меню.
- Кнопка переключателя включения/выключения: каждый узел имеет переключатель, позволяющий включить (возобновить) или выключить (приостановить) потоковую передачу данных из выбранных источников и к получателям.
В следующей таблице описано описание различных состояний узла:
| Состояние узла | Описание |
|---|---|
| Активно | Источник данных сейчас активен, и данные поступают в Eventstream или выходят из него. |
| Неактивное | Источник данных в настоящее время неактивен, и данные не передаются в Eventstream или из него. |
| Загрузка | Источник данных находится в процессе включения или отключения. |
| Ошибка | Источник данных в настоящее время приостановлен из-за ошибок. |
| Предупреждение | Источник данных работает, но возникают некоторые проблемы, хотя трафик данных продолжается. |
Активация или отключение узла с помощью переключателя
Для узлов, поддерживающих функции приостановки и возобновления работы, вы можете легко управлять потоком данных с помощью переключателя. Найдите нужный узел и переключите переключатель для активации (т. е. возобновления) или деактивации (то есть приостановки) трафика данных. Узлы, которые в настоящее время не поддерживают функцию приостановки и возобновления, не будут иметь переключатель.
В таблице ниже описаны доступные форматы резюме:
| Вариант продолжения | Описание |
|---|---|
| После последней остановки потоковой передачи | Воспроизведение возобновляется с того места, где потоковая передача была остановлена. |
| Сейчас | Возобновление воспроизведения с текущего момента |
| Настраиваемое время | Возобновление с настраиваемого времени |
Примечание.
При настройке потока событий источник, логика преобразования и назначение обычно добавляются вместе. По умолчанию при публикации потока событий серверные службы для приема данных и маршрутизации данных начинаются с Теперь соответственно. Однако прием данных может начинаться быстрее, чем маршрутизация данных, что приводит к приему некоторых данных в eventstream до полной инициализации маршрутизации. В результате эти данные могут не направляться в место назначения.
Типичным примером является источник CDC базы данных, где некоторые исходные данные моментального снимка могут оставаться в потоке событий без перенаправления в место назначения.
Чтобы устранить эту проблему, выполните следующие действия.
При настройке Eventhouse (обработка событий перед приемом данных) или точки назначения Lakehouse снимите флажок Активировать сбор данных после добавления источника данных.
Активируйте инжестию вручную после публикации Eventstream.
Используйте параметр пользовательского времени, чтобы выбрать более раннюю метку времени, обеспечивая правильную обработку и маршрутизацию исходных данных.
Ниже приведена подробная таблица узлов, поддерживающих функции приостановки и возобновления, а также доступные варианты возобновления:
| Узел | Тип | Поддерживает приостановку и возобновление работы | Варианты резюме |
|---|---|---|---|
| База данных Azure Data Explorer (предварительная версия) | Источник | Да | — При последней остановке потоковой передачи |
| Центры событий Azure | Источник | Да | — При последней остановке потоковой передачи -Сейчас - Пользовательское время |
| Пространство имен сетки событий Azure | Источник | Нет | |
| Служебная шина Azure (предварительная версия) | Источник | Да | — При последней остановке потоковой передачи |
| Центр Интернета вещей Azure | Источник | Да | — При последней остановке потоковой передачи -Сейчас - Пользовательское время |
| Пример данных | Источник | Да | -Сейчас |
| Погода в режиме реального времени | Источник | Да | — При последней остановке потоковой передачи |
| База данных SQL Azure CDC | Источник | Да | — При последней остановке потоковой передачи |
| База данных PostgreSQL CDC | Источник | Да | — При последней остановке потоковой передачи |
| CDC MongoDB (предварительная версия) | Источник | Да | — При последней остановке потоковой передачи |
| HTTP (предварительная версия) | Источник | Да | — При последней остановке потоковой передачи |
| CDC базы данных MySQL | Источник | Да | — При последней остановке потоковой передачи |
| Azure Cosmos DB CDC | Источник | Да | — При последней остановке потоковой передачи |
| SQL Server на виртуальной машине база данных CDC | Источник | Да | — При последней остановке потоковой передачи |
| CDC для управляемого экземпляра Azure SQL | Источник | Да | — При последней остановке потоковой передачи |
| Google Cloud Pub/Sub (сервис обмена сообщениями) | Источник | Да | — При последней остановке потоковой передачи |
| Потоки данных Amazon Kinesis | Источник | Да | — При последней остановке потоковой передачи |
| Confluent Kafka | Источник | Да | — При последней остановке потоковой передачи |
| Apache Kafka (предварительная версия) | Источник | Да | — При последней остановке потоковой передачи |
| Amazon MSK Kafka | Источник | Да | — При последней остановке потоковой передачи |
| Пользовательская конечная точка (т. е. пользовательское приложение в стандартной функциональности) | Источник | Нет | |
| Источник событий рабочей области Fabric | Источник | Нет | |
| События Fabric OneLake | Источник | Нет | |
| События задания Fabric | Источник | Нет | |
| Предварительная версия событий обзора емкости Fabric | Источник | Нет | |
| хранилище blob-объектов Azure | Источник | Нет | |
| MQTT (предварительная версия) | Источник | Да | — При последней остановке потоковой передачи |
| Cribl (предварительная версия) | Источник | Нет | |
| Solace PubSub+ (предварительная версия) | Источник | Да | — При последней остановке потоковой передачи |
| Лейкхаус (гибрид 'озера данных' и хранилища) | Назначение | Да | — При последней остановке потоковой передачи -Сейчас - Пользовательское время |
| Eventhouse (обработка событийных данных перед вводом) | Назначение | Да | — При последней остановке потоковой передачи -Сейчас - Пользовательское время |
| Пользовательская конечная точка (т. е. пользовательское приложение в стандартной функциональности) | Назначение | Нет | |
| Eventhouse (Прямая инжекция) | Назначение | Нет | |
| Активатор Fabric (предварительная версия) | Назначение | Да | — При последней остановке потоковой передачи -Сейчас - Пользовательское время |
| Производный поток | Назначение | Да | — При последней остановке потоковой передачи -Сейчас - Пользовательское время |