Как использовать веб-работу для отправки данных в концентратор событий с узлом JS

Question

Я ищу отправку данных из API (большой объем данных) в концентратор событий и обработку их с помощью потоковой аналитики Azure.Я ищу это в nodeJS.1, я должен отправить данные партии?2, я должен сделать несколько посылок за раз?Примечание. Я новичок в веб-заданиях Azure, поэтому, пожалуйста, подробно опишите решение.Заранее спасибо

Answer 1

1. Сначала создайте файл .js с именем run.js, а затем в этом месте используйте следующую команду для установки пакетов:

npm install @azure/event-hubs
npm install axios 

2. В файле run.js напишитеследующий код и запустите его локально, убедитесь, что нет ошибок:

const {EventHubClient} = require("@azure/event-hubs");
var axios = require('axios');

const connectionString = "Endpoint=sb://xxx.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=xxx";
const eventHubsName = "myeventhub";

async function main(){
    const client = EventHubClient.createFromConnectionString(connectionString,eventHubsName);
    var axios = require('axios');
    var response = await axios.get('https://nseindia.com/live_market/dynaContent/live_watch/stock_watch/nifty500StockWatch.json');
    var eventData = {body:response['data']['data'],partitionKey:"pk12345"};
    console.log(eventData);
    console.log("begin send...");
    await client.send(eventData);

    await client.close();
}

main().catch(err =>{
    console.log("Error occurred: ",err);
});

в том месте, где находится файл run.js, поместите все файлы в zip-файл.Вот мой пробег.zip:

затем перейдите на портал Azure, создайте веб-приложение (node.js), снимок экрана, как показано ниже (примечание, для стека времени выполнения, выберите узел):

когда веб-приложение будет готово, перейдите в веб-приложение -> Веб-задания -> выберите Добавить, затем во всплывающем окне загрузите файл run.zip.Для других настроек, пожалуйста, обратитесь к скриншоту ниже:

Когда веб-работа готова, она будет отправлять данные о событиях в концентратор событий каждую 1 минуту согласно конфигурации веб-задания.