fix: remove bigquery.readonly auth scope (#394)

* chore: use gapic-generator-python 0.63.2 * 🦉 Updates from OwlBot See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * fix!: remove bigquery.readonly auth scope PiperOrigin-RevId: 429331987 Source-Link: googleapis/googleapis@4b2bd26 Source-Link: googleapis/googleapis-gen@fa17f03 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZmExN2YwM2I1YWU5NjMxNmNkMDJmMjk5N2YyZmQxMTk2ZTAzNGU1ZSJ9 * 🦉 Updates from OwlBot See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md docs: add generated snippets PiperOrigin-RevId: 427792504 Source-Link: googleapis/googleapis@55b9e1e Source-Link: googleapis/googleapis-gen@bf4e86b Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYmY0ZTg2Yjc1M2Y0MmNiMGVkYjFmZDUxZmJlODQwZDdkYTBhMWNkZSJ9 Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com> Co-authored-by: Tim Swast <[email protected]>
googleapis · Feb 18, 2022 · e08d2fd · e08d2fd
1 parent cf5709e
commit e08d2fd
Show file tree

Hide file tree

Showing 50 changed files with 4,048 additions and 12 deletions.
diff --git a/google/cloud/bigquery_storage_v1/services/big_query_read/async_client.py b/google/cloud/bigquery_storage_v1/services/big_query_read/async_client.py
@@ -251,6 +251,26 @@ async def create_read_session(
         are created and do not require manual clean-up by the
         caller.
 
+
+        .. code-block::
+
+            from google.cloud import bigquery_storage_v1
+
+            def sample_create_read_session():
+                # Create a client
+                client = bigquery_storage_v1.BigQueryReadClient()
+
+                # Initialize request argument(s)
+                request = bigquery_storage_v1.CreateReadSessionRequest(
+                    parent="parent_value",
+                )
+
+                # Make the request
+                response = client.create_read_session(request=request)
+
+                # Handle the response
+                print(response)
+
         Args:
             request (Union[google.cloud.bigquery_storage_v1.types.CreateReadSessionRequest, dict]):
                 The request object. Request message for
@@ -368,6 +388,27 @@ def read_rows(
         Each request also returns a set of stream statistics
         reflecting the current state of the stream.
 
+
+        .. code-block::
+
+            from google.cloud import bigquery_storage_v1
+
+            def sample_read_rows():
+                # Create a client
+                client = bigquery_storage_v1.BigQueryReadClient()
+
+                # Initialize request argument(s)
+                request = bigquery_storage_v1.ReadRowsRequest(
+                    read_stream="read_stream_value",
+                )
+
+                # Make the request
+                stream = client.read_rows(request=request)
+
+                # Handle the response
+                for response in stream:
+                    print(response)
+
         Args:
             request (Union[google.cloud.bigquery_storage_v1.types.ReadRowsRequest, dict]):
                 The request object. Request message for `ReadRows`.
@@ -470,6 +511,26 @@ async def split_read_stream(
         original[0-j] = primary[0-j] and original[j-n] = residual[0-m]
         once the streams have been read to completion.
 
+
+        .. code-block::
+
+            from google.cloud import bigquery_storage_v1
+
+            def sample_split_read_stream():
+                # Create a client
+                client = bigquery_storage_v1.BigQueryReadClient()
+
+                # Initialize request argument(s)
+                request = bigquery_storage_v1.SplitReadStreamRequest(
+                    name="name_value",
+                )
+
+                # Make the request
+                response = client.split_read_stream(request=request)
+
+                # Handle the response
+                print(response)
+
         Args:
             request (Union[google.cloud.bigquery_storage_v1.types.SplitReadStreamRequest, dict]):
                 The request object. Request message for

diff --git a/google/cloud/bigquery_storage_v1/services/big_query_read/client.py b/google/cloud/bigquery_storage_v1/services/big_query_read/client.py
@@ -471,6 +471,27 @@ def create_read_session(
         are created and do not require manual clean-up by the
         caller.
 
+
+
+        .. code-block::
+
+            from google.cloud import bigquery_storage_v1
+
+            def sample_create_read_session():
+                # Create a client
+                client = bigquery_storage_v1.BigQueryReadClient()
+
+                # Initialize request argument(s)
+                request = bigquery_storage_v1.CreateReadSessionRequest(
+                    parent="parent_value",
+                )
+
+                # Make the request
+                response = client.create_read_session(request=request)
+
+                # Handle the response
+                print(response)
+
         Args:
             request (Union[google.cloud.bigquery_storage_v1.types.CreateReadSessionRequest, dict]):
                 The request object. Request message for
@@ -578,6 +599,28 @@ def read_rows(
         Each request also returns a set of stream statistics
         reflecting the current state of the stream.
 
+
+
+        .. code-block::
+
+            from google.cloud import bigquery_storage_v1
+
+            def sample_read_rows():
+                # Create a client
+                client = bigquery_storage_v1.BigQueryReadClient()
+
+                # Initialize request argument(s)
+                request = bigquery_storage_v1.ReadRowsRequest(
+                    read_stream="read_stream_value",
+                )
+
+                # Make the request
+                stream = client.read_rows(request=request)
+
+                # Handle the response
+                for response in stream:
+                    print(response)
+
         Args:
             request (Union[google.cloud.bigquery_storage_v1.types.ReadRowsRequest, dict]):
                 The request object. Request message for `ReadRows`.
@@ -671,6 +714,27 @@ def split_read_stream(
         original[0-j] = primary[0-j] and original[j-n] = residual[0-m]
         once the streams have been read to completion.
 
+
+
+        .. code-block::
+
+            from google.cloud import bigquery_storage_v1
+
+            def sample_split_read_stream():
+                # Create a client
+                client = bigquery_storage_v1.BigQueryReadClient()
+
+                # Initialize request argument(s)
+                request = bigquery_storage_v1.SplitReadStreamRequest(
+                    name="name_value",
+                )
+
+                # Make the request
+                response = client.split_read_stream(request=request)
+
+                # Handle the response
+                print(response)
+
         Args:
             request (Union[google.cloud.bigquery_storage_v1.types.SplitReadStreamRequest, dict]):
                 The request object. Request message for

diff --git a/google/cloud/bigquery_storage_v1/services/big_query_read/transports/base.py b/google/cloud/bigquery_storage_v1/services/big_query_read/transports/base.py
@@ -43,7 +43,6 @@ class BigQueryReadTransport(abc.ABC):
 
     AUTH_SCOPES = (
         "https://www.googleapis.com/auth/bigquery",
-        "https://www.googleapis.com/auth/bigquery.readonly",
         "https://www.googleapis.com/auth/cloud-platform",
     )
 

diff --git a/google/cloud/bigquery_storage_v1/services/big_query_write/async_client.py b/google/cloud/bigquery_storage_v1/services/big_query_write/async_client.py
@@ -239,6 +239,26 @@ async def create_write_stream(
         stream is considered committed as soon as an acknowledgement is
         received.
 
+
+        .. code-block::
+
+            from google.cloud import bigquery_storage_v1
+
+            def sample_create_write_stream():
+                # Create a client
+                client = bigquery_storage_v1.BigQueryWriteClient()
+
+                # Initialize request argument(s)
+                request = bigquery_storage_v1.CreateWriteStreamRequest(
+                    parent="parent_value",
+                )
+
+                # Make the request
+                response = client.create_write_stream(request=request)
+
+                # Handle the response
+                print(response)
+
         Args:
             request (Union[google.cloud.bigquery_storage_v1.types.CreateWriteStreamRequest, dict]):
                 The request object. Request message for
@@ -361,6 +381,37 @@ def append_rows(
            rpc), and the stream is explicitly committed via the
            ``BatchCommitWriteStreams`` rpc.
 
+
+        .. code-block::
+
+            from google.cloud import bigquery_storage_v1
+
+            def sample_append_rows():
+                # Create a client
+                client = bigquery_storage_v1.BigQueryWriteClient()
+
+                # Initialize request argument(s)
+                request = bigquery_storage_v1.AppendRowsRequest(
+                    write_stream="write_stream_value",
+                )
+
+                # This method expects an iterator which contains
+                # 'bigquery_storage_v1.AppendRowsRequest' objects
+                # Here we create a generator that yields a single `request` for
+                # demonstrative purposes.
+                requests = [request]
+
+                def request_generator():
+                    for request in requests:
+                        yield request
+
+                # Make the request
+                stream = client.append_rows(requests=request_generator())
+
+                # Handle the response
+                for response in stream:
+                    print(response)
+
         Args:
             requests (AsyncIterator[`google.cloud.bigquery_storage_v1.types.AppendRowsRequest`]):
                 The request object AsyncIterator. Request message for `AppendRows`.
@@ -417,6 +468,25 @@ async def get_write_stream(
     ) -> stream.WriteStream:
         r"""Gets information about a write stream.
 
+        .. code-block::
+
+            from google.cloud import bigquery_storage_v1
+
+            def sample_get_write_stream():
+                # Create a client
+                client = bigquery_storage_v1.BigQueryWriteClient()
+
+                # Initialize request argument(s)
+                request = bigquery_storage_v1.GetWriteStreamRequest(
+                    name="name_value",
+                )
+
+                # Make the request
+                response = client.get_write_stream(request=request)
+
+                # Handle the response
+                print(response)
+
         Args:
             request (Union[google.cloud.bigquery_storage_v1.types.GetWriteStreamRequest, dict]):
                 The request object. Request message for
@@ -500,6 +570,26 @@ async def finalize_write_stream(
         r"""Finalize a write stream so that no new data can be appended to
         the stream. Finalize is not supported on the '_default' stream.
 
+
+        .. code-block::
+
+            from google.cloud import bigquery_storage_v1
+
+            def sample_finalize_write_stream():
+                # Create a client
+                client = bigquery_storage_v1.BigQueryWriteClient()
+
+                # Initialize request argument(s)
+                request = bigquery_storage_v1.FinalizeWriteStreamRequest(
+                    name="name_value",
+                )
+
+                # Make the request
+                response = client.finalize_write_stream(request=request)
+
+                # Handle the response
+                print(response)
+
         Args:
             request (Union[google.cloud.bigquery_storage_v1.types.FinalizeWriteStreamRequest, dict]):
                 The request object. Request message for invoking
@@ -584,6 +674,27 @@ async def batch_commit_write_streams(
         multiple times. Once a stream is committed, data in the stream
         becomes available for read operations.
 
+
+        .. code-block::
+
+            from google.cloud import bigquery_storage_v1
+
+            def sample_batch_commit_write_streams():
+                # Create a client
+                client = bigquery_storage_v1.BigQueryWriteClient()
+
+                # Initialize request argument(s)
+                request = bigquery_storage_v1.BatchCommitWriteStreamsRequest(
+                    parent="parent_value",
+                    write_streams=['write_streams_value_1', 'write_streams_value_2'],
+                )
+
+                # Make the request
+                response = client.batch_commit_write_streams(request=request)
+
+                # Handle the response
+                print(response)
+
         Args:
             request (Union[google.cloud.bigquery_storage_v1.types.BatchCommitWriteStreamsRequest, dict]):
                 The request object. Request message for
@@ -673,6 +784,26 @@ async def flush_rows(
         Flush is not supported on the \_default stream, since it is not
         BUFFERED.
 
+
+        .. code-block::
+
+            from google.cloud import bigquery_storage_v1
+
+            def sample_flush_rows():
+                # Create a client
+                client = bigquery_storage_v1.BigQueryWriteClient()
+
+                # Initialize request argument(s)
+                request = bigquery_storage_v1.FlushRowsRequest(
+                    write_stream="write_stream_value",
+                )
+
+                # Make the request
+                response = client.flush_rows(request=request)
+
+                # Handle the response
+                print(response)
+
         Args:
             request (Union[google.cloud.bigquery_storage_v1.types.FlushRowsRequest, dict]):
                 The request object. Request message for `FlushRows`.