python - 为 Disco mapreduce 作业指定输出 uri

Question

我想让一个完整的迪斯科工作直接写入 mongodb。有没有一种简单的方法可以为 Disco 指定一个输出 url 以将其数据发送到？

Answer 1

Disco 和 MongoDB 之间没有直接的兼容层，尽管此类层的早期工作正在进行中。同时，我会让您的 Disco 作业写入 CSV 或 JSON（每行 1 个对象），您可以使用mongoimport. 有关更多详细信息，请参阅MongoDB 维基。