This is the support code and solutions for the NYC Taxi Tycoon Dataflow Codelab

In this codelab you learn how to process streaming data with Dataflow. The public emulated data stream is based on the NYC Taxi & Limousine Commission’s open dataset expanded with additional routing information using the Google Maps Direction API and interpolated timestamps to simulate a real time scenario.

The public Google Cloud Pubsub topic used in the codelab is available at: projects/pubsub-public-data/topics/taxirides-realtime

To test the public data stream you can create a subscription by using the gcloud cli. Make sure you have selected a project with billing and the PubSub API enabled.

gcloud alpha pubsub subscriptions create taxi-test-sub --topic projects/pubsub-public-data/topics/taxirides-realtime

Wait for a couple seconds before pulling a message from your subscription

gcloud alpha pubsub subscriptions pull projects/<your-project-id>/subscriptions/taxi-test-sub

Finally, delete the test subscription using

gcloud alpha pubsub subscriptions delete projects/<your-project-id>/subscriptions/taxi-test-sub

In the dataflow folder you find the solutions for all dataflow pipelines covered in the NYC Taxi Tycoon Dataflow Codelab

The visualizer code to display the output of your codelab dataflow pipelines can be found in the gh-pages branch. The visualizer is available hosted here.

Use: The NYC Taxi & Limousine Commission’s dataset is publicly available for anyone to use under the following terms provided by the Dataset Source —https://data.cityofnewyork.us/— and is provided "AS IS" without any warranty, express or implied, from Google. Google disclaims all liability for any damages, direct or indirect, resulting from the use of the dataset.

This is not an official Google product