1

changefeeds が正しいことを完全に理解しているかどうかはわかりません...私がする必要があるのは、次のように現在の日付に基づいてデータをフィルタリングすることです:

r.table("messages")
  .filter(
    r.row("start").lt(r.now().toISO8601())
      .and(r.row("end").gt(r.now().toISO8601()))
  )
  .changes()
  .run(conn, (err, cursor) => {
    if (err) {
      throw err;
    }

    cursor.each(function (err, row) {
      if (err) {
        throw err;
      }

     // do stuff here

    });
  });

});

このようなことをすることさえ可能ですか？または、行のフィールドが更新された場合にのみ .changes() が機能しますか?

4

1 に答える 1