Как мы можем получить данные, связанные с существующей темой Bluemix Message Hub, через node.js?

Я создал тему, используя node.js, и сопоставил ее с концентратором сообщений, используя прототип MessageHub.prototype.topics.create(topic). Я хочу добавить существующую тему концентратора сообщений в node.js и использовать данные из нее. Есть ли какая-нибудь функция для этого?


node.js ibm-cloud message-hub
person rajeswari    schedule 07.12.2016    source источник
comment
Пожалуйста, добавьте код того, что вы уже сделали.   -  person ralphearle    schedule 07.12.2016

Ответы (2)


arrow_upward
2
arrow_downward

@rajeswari Я предполагаю, что вы используете модуль node.js, который использует REST API концентратора сообщений.

Не стесняйтесь взглянуть на пример использования собственного клиента Node.js для Kafka,

https://github.com/ibm-messaging/message-hub-samples/tree/master/kafka-nodejs-console-sample

person Edoardo Comar    schedule 08.12.2016

arrow_upward
2
arrow_downward

@rajeswari вызов topics.create(topicName) просто запрашивает, чтобы тема была создана в MessageHub, и когда его Promise возвращает выходной ответ json на этот запрос, он доступен.

Если вы хотите получить сообщения из существующей темы, вы можете просто пропустить этот шаг и перейти непосредственно к созданию ConsumerInstance через MessageHub.prototype.consume, а затем вызвать MessageHub.ConsumerInstance.prototype.get(topicName) для возвращенного ConsumerInstance.

person Dominic Evans    schedule 07.12.2016