Pinned Repositories
airflow
Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
beam
Apache Beam is a unified programming model for Batch and Streaming data processing.
magic-modules
Add Google Cloud Platform support to Terraform
airflow
Apache Airflow
airflow-docker-image
cloudfunction-write-to-bigtable
A Cloud Function to insert a row to BigTable
twitter-to-kafka
Streaming Twitter's tweets to Apache Kafka
ryanyuan's Repositories
ryanyuan/airflow
Apache Airflow
ryanyuan/amazon-kinesis-data-analytics-developer-guide
Developer guide documentation for Amazon Kinesis Analytics
ryanyuan/aws-sdk-java-v2
The official AWS SDK for Java - Version 2
ryanyuan/beam
Apache Beam
ryanyuan/cloud-function-trigger-cloud-build
A Cloud Function to create a Cloud Build build instance
ryanyuan/dbt-tutorial
ryanyuan/diagrams
:art: Diagram as Code for prototyping cloud system architectures
ryanyuan/DogenationHK.github.io
io
ryanyuan/flink
Apache Flink
ryanyuan/freqtrade
Free, open source crypto trading bot
ryanyuan/google-cloud-java
Google Cloud Client Library for Java
ryanyuan/google-cloud-python
Google Cloud Client Library for Python
ryanyuan/iceberg
Apache Iceberg
ryanyuan/java-bigquery
ryanyuan/magic-modules
Automatically generate Google Cloud Platform support for OSS IaaC Projects
ryanyuan/pbe-with-md5-and-triple-des-python
Python implementation of PBEWithMD5AndTripleDES algorythm
ryanyuan/pubsub-message-generator
ryanyuan/pubsub-to-bigquery
ryanyuan/pubsub-to-cloudstorage
ryanyuan/pulumi-terraform-template
ryanyuan/python-bigquery
ryanyuan/python-bigtable
ryanyuan/python-pubsub
ryanyuan/python-storage
ryanyuan/sql-json-extract
ryanyuan/starrocks
StarRocks is a next-gen sub-second MPP database for full analytics scenarios, including multi-dimensional analytics, real-time analytics and ad-hoc query.
ryanyuan/terraform-count-to-for-each
Python script to convert Terraform state file from usage of count (index) to usage of for_each (key)
ryanyuan/terraform-provider-google
Terraform Google Cloud Platform provider
ryanyuan/terraform-provider-google-beta
Terraform Google Cloud Platform Beta provider
ryanyuan/tweets-realtime-ingestion
Source code for my PyGeekle22 "Building Real-time Data Pipeline with Apache Beam" speak. This is a realtime data pipeline to ingestion tweets from Pub/Sub to BigQuery using Apache Beam Python SDK.