You can use the JDBC driver. Here's a blog that describes JDBC usage in general: https://nl.devoteam.com/en/blog-post/querying-jdbc-database-parallel-google-dataflow-apache-beam/
On Mon, Jan 27, 2020 at 12:32 PM Alan Krumholz <[email protected]> wrote: > Hi, > We are using beam and (dataflow) at my company and would like to use it to > read and write data from snowflake. > > Does anybody know if there are any source/sink available for snowflake? > > if not, what would be the easiest way to create those? (maybe there is > something for sqlalchemy that we could leverage for that?) > > > Thanks so much! > > Alan >
