Skip to content

Change schema on model

Operation

Following is the process for operation related to project

Deploy/Schema Changes/Drop/Changes/Re-deploy a model

[1] PAUSED Google Stream

[2] Go to $STORAGE_STREAMING_BUCKET bucket then go to prefix folder: streaming-magnus/streaming/dawnbreaker2bq/cdc

  • Prepared to filter the target object with name <schema>_<table>

  • Drop table when the stream is already PAUSED

[3] Go to $BIGQUERY_STREAMING_DATASET dataset then prepared the table to delete

[4] Go back to any client, Python or Workbench

# Build the engine
>>> ENGINE = connect_with_connector(config=__CONFIG__)

# Syntax
# >>> <MODEL>.__table__.drop(ENGINE)
# >>> <MODEL>.__table__.create(ENGINE)
>>> HSC_OHLCV_EOD_INDEX.__table__.drop(ENGINE)
>>> HSC_OHLCV_EOD_INDEX.__table__.create(ENGINE)