小编cyb*_*bis的帖子

希望在事件流上进行实时度量计算,Azure中的一个好选择是什么？流分析还是风暴？我对SQL或Java感到满意,所以想知道其他差异是什么.

我正在尝试在 Ruby 中进行 avro 序列化。我已经编写了 JSON 模式，但是我喜欢将序列化数据作为 Ruby 中的字节而不是写入文件。

我的代码挂了类似的东西：

SCHEMA = {
           "type": "record",
           "name": "User",
           "fields" :
             [
               {"name": "name", "type": "string"},
               {"name": "id", "type": "long"},
               {"name": "city", "type": "string"}
             ]
         }.to_json

schema = Avro::Schema.parse(SCHEMA)
dw = Avro::IO::DatumWriter.new(schema)
buffer = StringIO.new
encoder = Avro::IO::BinaryEncoder.new(buffer)
???

我有 name、id 和 city 的值，想知道如何创建 User 对象并将其序列化到字符串/字节缓冲区中。