Materialized View を go で作る

ctx := context.Background()

projectId, err := metadata.ProjectID()
if err != nil {
    log.Fatal(err)
}

sql := `
  SELECT
    timestamp,
    day, 
    AVG(weight_pounds) AS weight_pounds
  FROM
    hoge.natality
  GROUP BY
    timestamp, 
    day  
`

// 1時間
refreshInterval := time.Duration(3600000)*time.Millisecond

view := &bigquery.MaterializedViewDefinition {
    EnableRefresh: true, // 自動更新を有効
    LastRefreshTime: time.Now(), // 設定するとテーブル情報に含まれる
    Query: sql,
    RefreshInterval: refreshInterval,
}

// クラスターインデックス
cluster := &bigquery.Clustering{
    Fields: []string{"day"},
}

// パーティショニングテーブル
timePartitioning := &bigquery.TimePartitioning {
    Expiration: 0,
    Field: "timestamp",
}

metaData := &bigquery.TableMetadata{
    MaterializedView: view,
    ExpirationTime: time.Now().Add(24*time.Hour), // View の有効期限
    TimePartitioning: timePartitioning,
    Clustering: cluster,
}

client, err := bigquery.NewClient(ctx, projectId)
if err != nil {
    log.Fatal(err)
}

tableRef := client.Dataset(datasetId).Table("natality_02")
if err := tableRef.Create(ctx, metaData); err != nil {
    log.Fatal(err)
}