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