This data pipeline demo repo has sample codes and commands to automatically process data files written to COS buckets and push data records to event stream with serverless code engine jobs. It also has sample consumer to consume the data records from event stream and further process the data before saving them back to COS bucket. - View it on GitHub