Skip to content

Instantly share code, notes, and snippets.

@evmin
Created March 30, 2019 09:13
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save evmin/c818523cc47d80c7953bd43f759cfa47 to your computer and use it in GitHub Desktop.
Save evmin/c818523cc47d80c7953bd43f759cfa47 to your computer and use it in GitHub Desktop.
from("google-pubsub:{{gcp_project_id}}:demo.event.bigquery")
.routeId(ROUTE_ID)
.to("jolt:transforms/demo_event.json?inputType=JsonString")
.setHeader(GoogleBigQueryConstants.PARTITION_DECORATOR,simple("${date:now:yyyyMMdd}"))
.log("Demo Event processed : ${body}")
.to("google-bigquery:{{gcp_project_id}}:demo:demo_event")
;
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment