Поделиться через

Планирование и запуск задач для обработки непрерывных данных с помощью триггера скользящего окна в Azure Logic Apps

  • Статья

Область применения: Azure Logic Apps (потребление)

Для регулярного запуска задач, процессов или заданий, которые должны обрабатывать данные в виде последовательных фрагментов, можно запускать рабочий процесс приложения логики с помощью триггера скользящего окна. Установите дату и время, а также часовой пояс для запуска рабочего процесса и его повторения. Если повторения по какой-либо причине будут пропущены, например из-за нарушений или отключения рабочих процессов, то триггер обработает их. Например, при синхронизации данных между базой и хранилищем резервных копий с помощью триггера скользящего окна можно сделать так, чтобы информация синхронизировалась без пропусков. Дополнительные сведения о встроенных триггерах и действиях по расписанию см. в статье Планирование и выполнение повторяющихся автоматизированных задач и рабочих процессов с помощью Azure Logic Apps.

Ниже приведены некоторые схемы и шаблоны, поддерживаемые данным триггером.

  • Незамедлительное выполнение и повторение каждые n секунд, минут, часов, дней, недель или месяцев.

  • Запуск по дате и времени, а затем запуск и повторение каждые n секунд, минут, часов, дней, недель или месяцев. Для этого триггера можно указать время начала в прошлом, в результате чего будут запущены все предыдущие повторения.

  • Каждое повторение можно выполнять с определенной задержкой перед выполнением.

Различия между этим триггером и триггером повторений, а также дополнительные сведения о расписании повторяющихся рабочих процессов см. в разделе Планирование и выполнение повторяющихся автоматизированных задач, процессов и рабочих процессов с помощью Azure Logic Apps.

Совет

Чтобы активировать приложение логики и выполнить его только один раз в будущем, ознакомьтесь с разделом Выполнение заданий только один раз.

Необходимые компоненты

Добавление триггера скользящего окна

  1. Войдите на портал Azure. Создайте пустое приложение логики.

  2. Когда откроется конструктор приложений логики, в поле поиска введите sliding window в качестве фильтра. В списке триггеров выберите в качестве первого шага в рабочем процессе приложения логики триггер Скользящее окно.

    Select

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

    Set interval and frequency

    Свойство Имя JSON Обязательное поле Тип Описание
    Интервал interval Да Целое Положительное целое число, которое описывает, как часто выполняется рабочий процесс с учетом заданной частоты. Ниже приведены минимальные и максимальные интервалы.

    - Месяц: 1-16 месяцев
    - Неделя: 1-71 недели
    - День: 1-500 дней
    - Час: 1–12 000 часов
    - Минута: 1-72 000 минут
    - Второй: 1-999 999 999 секунд

    Например, если интервал равен 6, а значение частоты — "Месяц", то повтор будет происходить каждые 6 месяцев.
    Периодичность frequency Да Строка Единица времени для повторения: Секунда, Минута, Час, День, Неделя или Месяц.

    Advanced recurrence options

    Чтобы настроить другие параметры повторения, откройте список Добавить новый параметр. Все выбранные параметры появляются в триггере после выбора.

    Свойство Обязательное поле Имя JSON Тип Описание
    Задержка Нет delay Строка Длительность задержки для каждого повторения (в формате даты и времени ISO 8601)
    Часовой пояс Нет timeZone Строка Применяется только при указании времени начала, так как этот триггер не принимает смещение от UTC. Выберите часовой пояс, который необходимо применить.
    Время начала Нет startTime Строка Укажите дату и время начала в этом формате:

    ГГГГ-ММ-ДДThh:mm:ss при выборе часового пояса

    -Или-

    ГГГГ-ММ-DDThh:mm:ssZ, если вы не выбираете часовой пояс

    Например, если требуется указать 18 сентября 2017 г. в 14:00, то используйте 2017-09-18T14:00:00 и выберите часовой пояс, например "Тихоокеанское время США (зима)". Или укажите 2017-09-18T14:00:00Z без часового пояса.

    Примечание. Это время начала должно соответствовать спецификации даты и времени ISO 8601 в формате UTC, но без смещения от UTC. Если вы не выберите часовой пояс, то необходимо в конце добавить букву Z без пробелов. Эта буква Z ссылается на соответствующее судовое время.

    В простых расписаниях время начала определяет первый случай выполнения задания, а в сложных расписаниях триггер срабатывает не раньше, чем наступит время начала. Как можно использовать дату и время начала?

  4. Теперь создайте оставшийся рабочий процесс с другими действиями.

Определение рабочего процесса — скользящее окно

В базовом определении рабочего процесса приложения логики с использованием JSON можно просмотреть определение триггера скользящего окна с выбранными параметрами. Чтобы просмотреть это определение, на панели инструментов конструктора выберите Представление кода. Чтобы вернуться в конструктор, выберите панель инструментов конструктора, Конструктор.

В этом примере показано, как определение триггера скользящего окна может выглядеть в определении базового рабочего процесса, где задержка для каждого почасового повторения составляет пять секунд:

"triggers": {
   "Recurrence": {
      "type": "SlidingWindow",
      "Sliding_Window": {
         "inputs": {
            "delay": "PT5S"
         },
         "recurrence": {
            "frequency": "Hour",
            "interval": 1,
            "startTime": "2019-05-13T14:00:00Z",
            "timeZone": "Pacific Standard Time"
         }
      }
   }
}

Следующие шаги