I would try a Cloud Dataflow streaming job. Both Datastore and Bigquery have "IO" connectors in Dataflow.