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通信

回答

相关问题