Skip to content
This repository has been archived by the owner on Nov 5, 2022. It is now read-only.

GoogleCloudPlatform/solutions-gcs-bq-streaming-functions-python

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

4 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Streaming data from Cloud Storage into BigQuery using Cloud Functions

This code looks at a complete ingest pipeline all the way from capturing streaming events (upload of files to Cloud Storage), to doing basic processing, errorm handling, logging and insert stream to bigquery. The example captures events from a bucket (object create) with Cloud Function, reads the file and stream the content (JSON) to a table in BigQuery. If something goes wrong, the function logs the results in Cloud Logging and Firestore, for post analysis. Finally the data from the BigQuery can be visualized using DataStudio or a front end Web UI with API integration.

For more details of how to execute the steps of this streaming pipeline, please take a look on Streaming data from Cloud Storage into BigQuery using Cloud Functions Tutorial.

About

Streaming data from Cloud Storage into BigQuery using Cloud Functions

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages