nodejs網絡服務器和python通信

我有一個簡單的網絡，可以顯示某股票代碼的股票價格流。 Web服務器是nodejs，股票處理的基礎結構是kafka，用python進行spark。流量是nodejs網絡服務器和python通信

googlefinnace - >卡夫卡（pythonfile 1） - >火花（pythonfile2） - >的NodeJS - > Web瀏覽器

的解釋：卡夫卡和點火過程的股票信息從谷歌金融，然後提供結果的NodeJS網絡服務器。但股票代碼是硬編碼爲「FB」。所以我想用戶可以在網上輸入所需的股票代碼，並且nodejs可以將它發送回kafka（pythonfile1）。我不知道如何在nodejs和kafka之間做到這一點。有人可以在這裏稱重嗎？

謝謝

來源

2017-01-06 nathan

有幾個非常好的nodejs卡夫卡客戶端。我個人使用節點rdkafka

https://github.com/Blizzard/node-rdkafka

使用這些中的NodeJS卡夫卡客戶可以發佈或訂閱從您的網絡的NodeJS應用程序的任何卡夫卡的話題。

來源

2017-01-07 16:54:38

感謝您的回覆。我的觀點是如何將用戶輸入的「stocksymbol」從js傳遞迴kafka服務器。沒有任何與卡夫卡經紀人相關的話題。 – nathan

卡夫卡服務器和卡夫卡經紀人是同一件事，所以你的問題不清楚。如果你想從nodejs中的web應用程序發佈到Kafka應用程序（可能用python編寫），你只需要發佈一個Key/Value對消息給你的後端python應用程序訂閱的kafka主題。如果在退出的node.js應用程序中將符號硬編碼爲'FB'，則只需更改該部分代碼以接受來自該使用的HTML表單，並使用提供的符號以及您的kafka消息的密鑰或值。消息可以是簡單的字符串或JSON。 –

nodejs網絡服務器和python通信

回答

相關問題