Apache beam with redis - select 数据库并从哈希中读取？

Question

我开始使用 Apache Beam，我想从存储在 Redis 中的散列中读取数据，我还需要 select 数据库（数字）。我查看了 RedisIO 的源代码，但它似乎不包含执行这些操作的能力。我是否遗漏了什么，或者我是否必须编写自己的实现来实现这一目标？

Answer 1

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

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