At my work we use Rethink changefeeds to accomplish literally the same task. We use changefeeds to filter and pipe data to Algolia and numerous other services. Works like a breeze and takes surprisingly little code to get up and running.
[0]: https://rethinkdb.com/docs/changefeeds/javascript/#including...