javagoogle-bigquerysiddhi

How to stream (query) data from BigQuery as source in a Siddhi App


Would like to develop a data processing pipeline application using siddhi (https://siddhi.io/) to read data from BigQuery and generate events. There are many references to use HTTP, RDBMS and TCP as sources, but not sure how exactly we could deal with BigQuery. Any reference or example on how to connect to BigQuery from Siddhi Application as source will help.


Solution

  • Currently, Siddhi doesn't have a native implementation to support this. A list of currently available extensions is listed here. You can try writing a custom connector by following this and this