Я пытаюсь использовать пакет @ azure / event-hubs npm (https://www.npmjs.com/package/@azure/event-hubs), но следующий код выдает ошибку, и я выполнил некоторый поиск, но я действительно не могу понять это.(возможно, какая-то глупая ошибка с моей стороны, но мне очень нужна помощь, чтобы найти ее).Я связываю все это с веб-пакетом, а затем использую его внутри тега скрипта.
код:
const { EventHubClient, EventPosition } = require('@azure/event-hubs');
const client = EventHubClient.createFromConnectionString(process.env["EVENTHUB_CONNECTION_STRING"], process.env["EVENTHUB_NAME"]);
async function main() {
const onError = (err) => {
console.log("An error occurred on the receiver ", err);
};
const onMessage = (eventData) => {
console.log(eventData.body);
const enqueuedTime = eventData.annotations["x-opt-enqueued-time"];
console.log("Enqueued Time: ", enqueuedTime);
};
const receiveHandler = client.receive("1", onMessage, onError, { eventPosition: EventPosition.fromEnqueuedTime(Date.now()) });
// To stop receiving events later on...
await receiveHandler.stop();
}
main().catch((err) => {
console.log(err);
});
Ошибка (путь удален с помощью "...."):
An error occurred on the receiver a: w(...) is not a function
at E._connect (file:///....../main.js:165:76736)
at E.connect (file:///...../main.js:165:76246)
at Promise (file:///..../main.js:30:205093)
at new Promise (<anonymous>)
at t.Connection.open (file:///..../main.js:30:204061)
at connection.isOpen.c.defaultLock.acquire (file:///..../main.js:157:128551)
at file:///..../main.js:165:123499
at r._promiseTry (file://...../main.js:165:124491)
at l (file:///...../main.js:165:123469)
at r.acquire (file:///...../main.js:165:123961)
webpack.config.js:
const path = require('path');
module.exports = {
entry: './www/src/index.js',
output: {
filename: 'main.js',
path: path.resolve(__dirname, 'www/dist')
},
node: {
fs: 'empty',
net: 'empty',
tls: 'empty'
}
};
Спасибо за любую помощь!