Данные не отображаются в обозревателе данных Azure после приема из концентратора событий
Я хочу отправить данные из своего кода в концентратор событий Azure и, наконец, в обозреватель данных Azure. Я отправил данные json в концентратор событий, используя машинописный текст с помощью следующего фрагмента кода:
async function sendToEventHub(data: any) {
const producerClient = new EventHubProducerClient(connectionString, eventHubName);
let batch = await producerClient.createBatch();
batch.tryAdd({body: data});
await producerClient.sendBatch(batch);
await producerClient.close();
};
const data = {
"runId": "abc",
"startTime": "1234",
"endTime": "1234",
"elapsedTime": "1234"
};
sendToEventHub(data).catch((err) => {
console.info("Error occurred: ", err);
});
Я вижу входящие сообщения в мониторах концентратора событий. Затем я создал кластер Azure Data Explorer и базу данных. Я ввел данные в эту базу данных и создал новую таблицу «тест». Но когда я выполнил запрос, чтобы увидеть содержимое таблицы, он оказался пустым. Снимок можно посмотреть здесь, Смотрите также это.
Я могу интерпретировать, что данные поступают в проводник данных, но не могут отображаться, поскольку схема таблицы (имена и типы столбцов) была создана с помощью самих данных.
Что мне здесь не хватает? Я мог видеть данные до последнего шага в предварительном просмотре приема данных здесь.
Ответы 2
Я использовал ваш код, но он сработал для меня. Единственное изменение, которое я сделал, это предоставление данных в правильном формате JSON.
{ "name": "Afreen", "age": 26 }
Код:
import { EventHubProducerClient, EventData } from "@azure/event-hubs";
const connectionString = "Your Event Hub connection string";
const eventHubName = "Event Hub name";
async function sendToEventHub(data: any) {
const producerClient = new EventHubProducerClient(connectionString, eventHubName);
let batch = await producerClient.createBatch();
batch.tryAdd({body: data});
await producerClient.sendBatch(batch);
await producerClient.close();
};
const data = {
"runId": "xyz",
"startTime": 1234,
"endTime": 1234,
"elapsedTime": 1234
};
sendToEventHub(data).catch((err) => {
console.info("Error occurred: ", err);
});
Обозреватель данных Azure:
Судя по приложенным вами изображениям, ваши данные не обрабатываются в соответствии с указанным вами форматом. Итак, вы должны проверить:
- Как определяется ваше подключение для передачи данных? Каков формат данных?
- Проверьте, не отображается ли что-либо с ошибками приема .show