Mongo DB Stream - Bigquery Dataflow

Installation

  1. Clone the repository

    git clone https://github.com/anasvakyathodi/mongodb-bq-dataflow.git
    
    cd mongodb-bq-dataflow
  2. Install dependencies

    npm install

Running

  • ADD MONGO_URL in .env

npm run dev

working

1. On insertion in collection "comments"
2. New record will be added to bigquery table.