Attempt to reproduce https://github.com/GoogleCloudPlatform/google-cloud-python/issues/5539

reproduce_gcp_5539.py

import pprint

from google.api_core import exceptions
from google.cloud import bigquery


def setup_dataset(client):
    ds_ref = client.dataset('gcp_5539')
    try:
        return client.get_dataset(ds_ref)
    except exceptions.NotFound:
        return client.create_dataset(
            dataset=bigquery.Dataset(ds_ref))


def setup_table(client, dataset):
    table_ref = dataset.table('test')
    schema = [
        bigquery.SchemaField('doi', 'STRING', 'REQUIRED', None, ()),
        bigquery.SchemaField('subjects', 'STRING', 'REPEATED', None, ()),
    ]
    try:
        return client.get_table(table_ref)
    except exceptions.NotFound:
        return client.create_table(
            table=bigquery.Table(table_ref, schema))


def main():
    client = bigquery.Client()
    dataset = setup_dataset(client)
    table = setup_table(client, dataset)
    print('Schema:')
    print('-' * 78)
    pprint.pprint(table.schema)
    print('-' * 78)

    rows = [
        {"doi": "test-{}".format(i), "subjects": ["something"]}
        for i in range(1000)
    ]
    errors = client.insert_rows(table, rows)
    print('Errors:')
    print('-' * 78)
    pprint.pprint(errors)
    print('-' * 78)

    rows = client.list_rows(table)
    print('Fetched:')
    print('-' * 78)
    pprint.pprint(list(rows))
    print('-' * 78)


if __name__ == '__main__':
    main()