【发布时间】:2015-10-08 20:27:36
【问题描述】:
我正在尝试将从 mongo 读取的 BSONDocument 发布到 AWS Kinesis 流。但是 Kinesis API 需要消息作为字节数组。有什么方法可以将 BSONDocument(特别是 reactivemongo.bson.BSONDocument)转换为字节数组?
【问题讨论】:
-
EDIT reactivemongo.bson.BSONDocument 对象具有写入不同类型缓冲区的 write 方法。 val buffer = new ArrayBSONBuffer() BSONDocument.write(doc, buffer) val data = buffer.array
标签: mongodb reactivemongo