azure-eventhub

0зной

1ответ

Spark Streaming Union Stream - распараллеливание

Это может быть основной вопрос, но у меня есть некоторые проблемы с пониманием этого. В настоящее время я использую концентраторы событий Microsoft Azure, которые транслируются в приложении Spark/Scal

0зной

1ответ

azure eventhub event persistence при чтении потоковым аналитическим заданием

У меня есть небольшое доказательство концепции, вместе взятой, которая имеет eventhub, потоковая аналитика, подключенная к ней, которая затем выводит события непосредственно в базу данных. Насколько я

0зной

3ответ

Как отправить сжатые данные в Azure Stream Analytics?

У меня есть система сбора данных с устройства и отправки данных в формате JSON в Azure Eventhub. Существует поток аналитики потока Azure, который берет данные из eventhub и выводит его в PowerBI. Он о

1зной

1ответ

Улучшение кода для чтения сообщений из концентратора событий, в зависимости от даты последнего сообщения

Следующий код подключается к концентратору событий Azure, он выполняет итерацию по всем разделам, а затем считывает сообщения, которые должны обрабатываться и вставляться в базу данных (что нужно сдел

2зной

4ответ

Azure IoT Hub AMQP Communication Multiplexing

В некоторых из Microsoft documentation для работы с концентраторами Azure IoT упоминается, что можно мультиплексировать связь нескольких устройств под одним TLS-соединением (используя протокол AMQP) д

1зной

1ответ

получения сообщения об ошибке не Azure EventHub в те-

Я пытаюсь отправить строку в EventHub и я написал этот код: private static void sendPOST(ValueChangeMessage valueChangeMessage) throws IOException { try { // final String namespaceName = ""; /

0зной

1ответ

Azure поток Аналитика событий концентратор Нет событий

Azure Stream Analytics работа экспортирует события на Azure Event Hub, основываясь на этом Query: SELECT ipAddress, httpRequestTime INTO Outlet FROM Inlet TIMESTAMP BY HttpRequestTime Нет событий

0зной

1ответ

поток аналитика концентратор Событие Выход

Следующая Stream AnalyticsQuery подсчитывает количество событий, сгруппированные по IP-адрес, в 10-секундными интервалами: Sliding Window Select Min(Time) as FirstHit, Max(Time) as LastHit,