使用 `now()` 的 RethinkDB changefeed 过滤

Question

我希望使用 RethinkDB changefeeds 创建一种 'time tigger'：

        return r.
            Table("Checks").
            Filter(r.Row.Field("ScheduledFor").Le(r.Now())).
            Changes(r.ChangesOpts{
                    IncludeInitial: true,
            }).Run(db)

然而，虽然它会拾取最初满足 Filter 谓词的事物，但它似乎不会拾取 ScheduledFor 从未来变为过去的记录。

即r.Now() 似乎在服务器收到后就进行了评估，再也不会进行评估。

有没有办法让Now()项动态求值？或者我应该做一个 table 扫描？

Answer 1

目前 r.now 总是计算服务器收到查询的时间。最好对安排在上次 table 扫描和当前时间之间的任何文档重复执行 table 扫描。

使用 `now()` 的 RethinkDB changefeed 过滤

RethinkDB changefeed filtering using `now()`

go

rethinkdb