Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

docs: recommend insert_rows_json to avoid call to tables.get #258

Merged
merged 4 commits into from Sep 15, 2020
Merged

docs: recommend insert_rows_json to avoid call to tables.get #258

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
012934c
docs: recommend insert_rows_json to avoid call to tables.get
tswast Sep 11, 2020
529f480
Merge branch 'master' into pr253-insert-rows-json
tswast Sep 11, 2020
f356a87
update comments
tswast Sep 14, 2020
a3b86be
Merge remote-tracking branch 'upstream/master' into pr253-insert-rows…
tswast Sep 14, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
13 changes: 8 additions & 5 deletions samples/table_insert_rows.py
View file
Open in desktop
Expand Up @@ -16,19 +16,22 @@
def table_insert_rows(table_id):

# [START bigquery_table_insert_rows]

from google.cloud import bigquery

# Construct a BigQuery client object.
client = bigquery.Client()

# TODO(developer): Set table_id to the ID of the model to fetch.
# TODO(developer): Set table_id to the ID of table to append to.
# table_id = "your-project.your_dataset.your_table"

table = client.get_table(table_id) # Make an API request.
rows_to_insert = [(u"Phred Phlyntstone", 32), (u"Wylma Phlyntstone", 29)]
rows_to_insert = [
{u"full_name": u"Phred Phlyntstone", u"age": 32},
{u"full_name": u"Wylma Phlyntstone", u"age": 29},
]

errors = client.insert_rows(table, rows_to_insert) # Make an API request.
errors = client.insert_rows_json(table_id, rows_to_insert) # Make an API request.
if errors == []:
print("New rows have been added.")
else:
print("Encountered errors while inserting rows: {}".format(errors))
# [END bigquery_table_insert_rows]
15 changes: 9 additions & 6 deletions samples/table_insert_rows_explicit_none_insert_ids.py
View file
Open in desktop
Expand Up @@ -16,21 +16,24 @@
def table_insert_rows_explicit_none_insert_ids(table_id):

# [START bigquery_table_insert_rows_explicit_none_insert_ids]

from google.cloud import bigquery

# Construct a BigQuery client object.
client = bigquery.Client()

# TODO(developer): Set table_id to the ID of the model to fetch.
# TODO(developer): Set table_id to the ID of table to append to.
# table_id = "your-project.your_dataset.your_table"

table = client.get_table(table_id) # Make an API request.
rows_to_insert = [(u"Phred Phlyntstone", 32), (u"Wylma Phlyntstone", 29)]
rows_to_insert = [
{u"full_name": u"Phred Phlyntstone", u"age": 32},
{u"full_name": u"Wylma Phlyntstone", u"age": 29},
]

errors = client.insert_rows(
table, rows_to_insert, row_ids=[None] * len(rows_to_insert)
errors = client.insert_rows_json(
table_id, rows_to_insert, row_ids=[None] * len(rows_to_insert)
) # Make an API request.
if errors == []:
print("New rows have been added.")
else:
print("Encountered errors while inserting rows: {}".format(errors))
# [END bigquery_table_insert_rows_explicit_none_insert_ids]