I am trying to develop a simple dataflow pipeline that will read string data from a pub/sub topic called ‘iot’ continuously, process it in a simple way , and save it in a required schema format to a firestore collection ‘vehicle-tracking’.