Open acmiyaguchi opened 5 years ago
PubSub has the SQL capabilities via Apache Calcite and Beam: https://cloud.google.com/dataflow/docs/guides/sql/dataflow-sql-ui-walkthrough#assign-pubsub-schema
The format is in YAML, and fits in the scope of this tool. Here's the example taken from the docs page.
- column: event_timestamp description: Pub/Sub event timestamp mode: REQUIRED type: TIMESTAMP - column: attributes description: Pub/Sub message attributes mode: NULLABLE type: MAP<STRING,STRING> - column: payload description: Pub/Sub message payload mode: NULLABLE type: STRUCT subcolumns: - column: tr_time_str description: Transaction time string mode: NULLABLE type: STRING - column: first_name description: First name mode: NULLABLE type: STRING - column: last_name description: Last name mode: NULLABLE type: STRING - column: city description: City mode: NULLABLE type: STRING - column: state description: State mode: NULLABLE type: STRING - column: product description: Product mode: NULLABLE type: STRING - column: amount description: Amount of transaction mode: NULLABLE type: FLOAT
PubSub has the SQL capabilities via Apache Calcite and Beam: https://cloud.google.com/dataflow/docs/guides/sql/dataflow-sql-ui-walkthrough#assign-pubsub-schema
The format is in YAML, and fits in the scope of this tool. Here's the example taken from the docs page.