来自的OpenWhisk和二进制数据

Question

我们有一个模拟设备正在用NanoMSG创建数据，其有效载荷为Google FlatBuffers (二进制)。

我们希望用OpenWhisk触发此数据的模式，并使用Flatbuffer编码的响应进行响应。

假设延迟和吞吐量在这里不是一个大问题。

我们可以采取哪种方法：

1. 编写一个中继器，将Flatbuffer转换为JSON (FB有一个实用程序来完成此操作)，然后将数据放到由OpenWhisk监听的AMQP上？(我们有熟悉AMQP的人，但不是Kafka。
2. 尝试使用Kafka做一些事情，这似乎(可能只是IBM版本)直接处理二进制Flabuffers (可能仍然需要从NanoMSG到Kafka )。例如。

如何在Bluemix中从OpenWhisk平台调用IoT操作

https://medium.com/openwhisk/serverless-transformation-of-iot-data-in-motion-with-openwhisk-272e36117d6c

不确定是否仍然不需要Flatbuffers、JavaScript反序列化程序和序列化程序将JavaScript中的二进制based64数据转换为JSON

1. 学习Kakfa，然后将NanoMsg有效负载(Flatbuffers )转换为JSON。
2. 还有别的吗？

有人在这方面有直接经验吗？

更新

谢谢詹姆斯，这些都是现场链接。但它确实提出了一些次要问题：

1. 如果数据在Google模式中，那么使用FlatBuffers二进制转换似乎没有任何好处，因为来自base64的mux/demux仍然需要在javascript层执行。
2. 令人稍感不安的是，卡夫卡(以其低延迟著称)正在分批处理这些事件。这确实会影响延迟，当一个人有物联网(传感器数据)，需要在一个闭环的执行机构(传感器->控制->执行器)是一个常见的机器人模型，这是非常接近我们正在做的事情。目前我们并不是在推动延迟问题，但我可以看到一些新出现的情况，我们需要低延迟。卡夫卡打呼机提供商社区对此有何想法？
3. 我一定是错过了什么，但是AMQP供应商说它正在使用https://github.com/amqp/rhea#receiver。这似乎为编写处理传感器流数据的简单触发器/规则提供了所有需要。为什么要使用OpenWhisk？

Answer 1

这两种选择都是合理的。OpenWhisk操作接收并返回JSON消息。传递给这些函数的二进制数据必须由Base64编码。

如果使用AMQP提要，则可以手动将二进制数据转换为JSON。

Kafka饲料供应商确实支持二进制输入值的自动编码(使用isB进制*参数)。

Kafka将批量消息推送到OpenWhisk操作。这与消息队列不同，消息队列一次推送一条消息。这个提要提供程序是内置的OpenWhisk。

有一个为AMQP 这里提供外部社区提要的供应商。这需要您手动安装和运行它。