Настройка кластерного столбца в BigQuery Python API - PullRequest
1 голос
/ 06 марта 2019

Я пытаюсь создать кластерную таблицу в BigQuery.

Когда я тестирую ее в пользовательском интерфейсе, она отлично работает:

CREATE OR REPLACE TABLE `project_id_xyz.temp.clustering`
PARTITION BY date
CLUSTER BY cluster_col AS
SELECT CURRENT_DATE() as date, 1 as cluster_col

Однако, когда я пытаюсь сделать то же самое через Google-bigquery == 1.9.0 в python (3.7.1), таблица создается и разбивается, но не кластеризуется.Как видно на вкладке «детали» в пользовательском интерфейсе.

Вот фрагмент, который я использую для создания таблицы.

dataset = client.dataset("temp")
table = dataset.table("clustering_test")
job_config = bigquery.QueryJobConfig()
job_config.destination = table
job_config.write_disposition = "WRITE_TRUNCATE"

time_partitioning = TimePartitioning()
time_partitioning.field = "date"
job_config.time_partitioning = time_partitioning
job_config.clustering_fields = ["cluster_col"]

sql = """
    SELECT CURRENT_DATE() as date, 1 as cluster_col
"""
query_job = client.query(
    sql,
    location='US',
    job_config=job_config)

query_job.result() 

Код кажется очень простым и также не выдает никаких исключений,

Есть ли что-то очевидное, что я делаю не так?

1 Ответ

1 голос
/ 07 марта 2019

Я запускаю ваш код Python и могу подтвердить, что он работает должным образом с настройками кластера.

Решение вашей проблемы с использованием Python 3.6.7 состоит в том, чтобы создать чистую версию и снова запустить ваш код

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...