Estaba usando la versión azure/event-hubs 1.0.8 en nodejs para enviar los datos a una identificación de partición específica. A continuación se muestra el código de muestra
¿Podría alguien ayudarme a enviar datos al evento a una identificación de partición específica usando la versión 5.6.0 de azure/event-hubs en nodejs? Investigué mucho pero no pude encontrar ninguna fuente. ¡Cualquier ayuda sería apreciada!
A continuación se muestra el código para EventHub 5.6.0
const insertOneInPartition = (data, partition, eventsHub) => { const dataToInsert = { body: { ...data } }; return new Promise((resolve, reject) => { eventsHub.createBatch({ partitionId : partition }).then(async eventDataBatch => { if (data) { eventDataBatch.tryAdd(dataToInsert); await eventsHub.sendBatch(eventDataBatch); resolve(eventsHub); } else { // eslint-disable-next-line prefer-promise-reject-errors reject('error'); } }).catch(error => { reject(error); }); }); };Para los clientes de nodejs , vea createBatch() que toma un argumento de opciones que puede contener el ID de partición o la clave de partición, vea el código de muestra de sendEvents en github , vea la línea 41. Puede usar esta aplicación de navegador para enviar mensajes de prueba a su partición específica .
Para los clientes de Javascript , debe pasar el partition ID al crear el lote. enmarque las opciones de lote con el ID de partición y envíelo a create_batch (batchOptions), consulte la línea 35 para configurar el ID de partición en el ejemplo de código en https://github.com/Azure/azure-sdk-for-js/blob/master/sdk/eventhub /event-hubs/samples/v5/javascript/sendEvents.js