Squeak.ru - шаблоны программирования

Azure Stream Analytics: вращающееся окно

У меня 2 вопроса:

1) Как работает Tumbling Window?

Итак, предположим, что события происходят постоянно. Я делаю Tumbling (час, 1)
Затем Stream Analytics будет ждать 1 час, сгруппировать их и дать мне 1 запись

или как только наступит событие, оно выдаст мне запись, сгруппировав данные за последний 1 час?

2) В моем сценарии платеж поступает постоянно, мне нужно иметь сумму всей суммы за этот день, каждый раз, когда приходит транзакция, она должна давать мне СУММУ.

Итак, предположим, что ниже приведены мои данные о транзакции

Testdata

Итак, как мы видим на изображении

  • When Transaction comes 30/10/2019 5:08:06 Stream analytics should give Amount $10
    • When Transaction comes 30/10/2019 5:08:07 Stream analytics should give Amount $20
    • Когда приходит транзакция 30.10.2019 5:08:08 Stream Analytics должен дать сумму 30 долларов
    • Когда приходит транзакция 30.10.2019 6:08:09 Stream Analytics должен дать сумму 40 долларов
    • Когда приходит транзакция 30.10.2019 7:08:11 Stream Analytics должен дать сумму $ 50
    • Когда приходит транзакция 30.10.2019 11:08:12 Stream Analytics должен дать сумму $ 60
azure
31.10.2019

Ответы:


1

Для вопроса №1 SA будет ждать 1 час, а затем сгруппировать и предоставить вам одну запись в качестве вывода.

Оконные функции (Azure Stream Analytics)

Каждая оконная операция выводит событие в конце окна. Окна Azure Stream Analytics открываются во время начала окна и закрываются во время окончания окна. Например, если у вас есть 5-минутное окно с 12:00 до 12:05, в это окно будут включены все события с меткой времени больше 12:00 и до 12:05 включительно. Результатом окна будет отдельное событие на основе используемой агрегатной функции с меткой времени, равной времени окончания окна.

Что касается вопроса № 2, я считаю, что вы можете использовать окно прыжка и определить свою продолжительность за последний 1 день (86400 секунд), например:

SELECT Amount, SUM(Amount) as TotalTransactions 
FROM <YourSAInput> TIMESTAMP BY TransactionDate
GROUP BY Amount, HoppingWindow(seconds, 86400, 1)

Окно перехода (Azure Stream Analytics) < / а>

Спецификация окна переключения состоит из трех параметров: timeunit, windowsize (как долго длится каждое окно) и hopsize (на сколько каждый окно перемещается вперед относительно предыдущего).

Надеюсь это поможет.

01.11.2019
  • Спасибо, jadali за ваше драгоценное время и комментарий. Я попробовал Hopping widow, но эта проблема возникла, так как я не могу указать 86400. Предположим, у меня есть транзакция в 03/11 18:40 10 долларов и еще одна 04/11 05:58 am 20 долларов. он не должен суммировать эти два, поскольку даты разные. Я хочу, чтобы он был динамическим, так как он должен суммировать все транзакции за этот день только до этого времени, начиная с 00:00 до текущего времени того же дня 04.11.2019
    • Новые материалы
    Угловая структура архитектуры
    Обратите внимание, что эта статья устарела, я решил создать новую с лучшей структурой и с учетом автономных компонентов: https://medium.com/@marekpanti/angular-standalone-architecture-b645edd0d54a..
    «Данные, которые большинство людей используют для обучения своих моделей искусственного интеллекта, поставляются со встроенным…
    Первоначально опубликовано HalkTalks: https://hacktown.com.br/blog/blog/os-dados-que-a-maioria-das-pessoas-usa-para-treinar-seus-modelos-de-inteligencia-artificial- ja-vem-com-um-vies-embutido/..
    Сильный ИИ против слабого ИИ: различия парадигм искусственного интеллекта
    В последние годы изучению и развитию искусственного интеллекта (ИИ) уделяется большое внимание и прогресс. Сильный ИИ и Слабый ИИ — две основные парадигмы в области искусственного интеллекта...
    Правильный способ добавить Firebase в ваш проект React с помощью React Hooks
    React + Firebase - это мощная комбинация для быстрого и безопасного создания приложений, от проверки концепции до массового производства. Раньше (знаете, несколько месяцев назад) добавление..
    Создайте API с помощью Python FastAPI
    Создание API с помощью Python становится очень простым при использовании пакета FastAPI. После установки и импорта вы можете создать приложение FastAPI и указать несколько конечных точек. Каждой..
    Веселье с прокси-сервером JavaScript
    Прокси-серверы JavaScript — это чистый сахар, если вы хотите создать некоторую общую логику в своих приложениях, чтобы облегчить себе жизнь. Вот один пример: Связь клиент-сервер Мы..
    Получить бесплатный хостинг для разработчиков | Разместите свой сайт за несколько шагов 🔥
    Статические веб-сайты — это веб-страницы с фиксированным содержанием и его постоянным содержанием. Но теперь статические сайты также обрабатывают динамические данные с помощью API и запросов...