Изменить определение представления BigQuery с помощью Python - PullRequest
Новая
       35

Изменить определение представления BigQuery с помощью Python

0 голосов
/ 16 сентября 2018

Я пытаюсь обновить представление в bigquery через python. Я смог создать представление, используя следующий подход: 

def createView(client):
    viewDataset = 'dataset'
    viewName = 'name'
    view_ref = client.dataset(viewDataset).table(viewName)
    view = bigquery.Table(view_ref)
    view_sql = """
    select * from '{}.{}' where thing = 2
    """".format(viewDataSet, viewName)
    view.view_query = view_sql
    client.create_table(view)

(Код для пояснения)

Это работало нормально и создавало представление. Затем я хотел запустить функцию, которая обновляет определение представления. Я повторно использовал тот же код, и он потерпел неудачу с ошибкой, говоря, что представление уже существует - это имеет смысл. Затем я последовал этому примеру здесь; https://cloud.google.com/bigquery/docs/managing-views

Использование кода для обновления SQL-запроса представлений. В основном я поменял линию 

client.create_table(view)

для 

client.update_table(view)

Я получаю сообщение об ошибке, говоря, что я не добавил атрибут fields ... Поскольку я являюсь представлением, я бы не стал этого делать.

Может кто-нибудь сказать мне правильный способ использовать Python для обновления существующего представления BigQuery?

Приветствия

1 Ответ

0 голосов
/ 26 октября 2018

Смотри!Вы используете: 

"select * from '{}.{}' where thing = 2"

Обратите внимание: 

from '{}.{}'

Но на таблицу следует ссылаться как: 

from '{}.{}.{}'

Этот фрагмент кода мне подходит:

from google.cloud import bigquery

if __name__ == "__main__":
    client = bigquery.Client()

    dataset_view_id= 'dataset_name'
    table_view_id = 'view_name'

    view = bigquery.Table(client.dataset(dataset_view_id).table(table_view_id))


    ##############        
    ###what whas in that table? request table info
    ##############
    get_view = client.get_table(view)  # API Request

    # Display OLD view properties
    print('View at {}'.format(get_view.full_table_id))
    print('View Query:\n{}'.format(get_view.view_query))


    ##############
    #update the table:
    ##############
    sql_template = (
        'SELECT * FROM `{}.{}.{}` where disease="POLIO" ')

    source_project_id = "project_from_the_query"
    source_dataset_id = "dataset_from_the_query"
    source_table_id = "table_from_the_query"

    view.view_query = sql_template.format(source_project_id, source_dataset_id, source_table_id)

    view = client.update_table(view, ['view_query'])  # API request


    ##############
    #Now print the view query to be sure it's been updated:
    ##############    
    get_view = client.get_table(view)  # API Request

    # Display view properties
    print('\n\n NEW View at {}'.format(get_view.full_table_id))
    print('View Query:\n{}'.format(get_view.view_query))
    # [END bigquery_get_view]
...