带有redis的Apache梁-选择数据库并从哈希中读取？

Question

我从 Apache Beam 开始，我想从存储在 Redis 中的哈希中读取数据，我还需要选择数据库（编号）。我查看了 RedisIO 的来源，但它似乎不包括执行上述任何一项的能力。我错过了什么，还是我必须编写自己的实现来实现这一点？

Answer 1

很遗憾，目前不支持这些参数。

目前，最简单的方法是扩展 RedisIO.BaseReadFn 并覆盖 setup 和 teardown。