Я использую BigQuery Storage API (бета) для загрузки большого набора данных в фрейм данных.
Вот мой код:
from google.cloud import bigquery
from google.cloud import bigquery_storage_v1beta1
bqclient = bigquery.Client(
project='i-xxxx')
bqstorageclient = bigquery_storage_v1beta1.BigQueryStorageClient()
df= bqclient.query(query_string,job_config=query_config).result().to_dataframe(bqstorage_client=bqstorageclient)
Но я получил следующую ошибку:
TypeError: to_dataframe() got an unexpected keyword argument 'bqstorage_client'
Есть идеи, что это за ошибка?Это ошибка, или я здесь отсутствует?
Обновлено: pip freeze по запросу:
google-api-core==1.8.0
google-api-python-client==1.7.7
google-auth==1.6.1
google-auth-httplib2==0.0.3
google-auth-oauthlib==0.2.0
google-cloud-bigquery==1.9.0
google-cloud-bigquery-storage==0.2.0
google-cloud-core==0.29.1
google-cloud-storage==1.13.2
google-resumable-media==0.3.1
googleapis-common-protos==1.5.5