feat: [google-cloud-bigquery-analyticshub] Support new feature Sharing Cloud Pubsub Streams via AH (GA) and Subscriber Email logging feature (googleapis#13713)

- [ ] Regenerate this pull request now.

PiperOrigin-RevId: 740660889

Source-Link:
googleapis/googleapis@b64f36a

Source-Link:
https://github.com/googleapis/googleapis-gen/commit/287281224e62b313c0aebd87967b72655c772ccb
Copy-Tag:
eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWJpZ3F1ZXJ5LWFuYWx5dGljc2h1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMjg3MjgxMjI0ZTYyYjMxM2MwYWViZDg3OTY3YjcyNjU1Yzc3MmNjYiJ9

---------

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>

Author: gcf-owl-bot[bot]

packages/google-cloud-bigquery-analyticshub/google/cloud/bigquery_analyticshub/__init__.py

@@ -34,6 +34,7 @@
     DeleteSubscriptionRequest,
     DestinationDataset,
     DestinationDatasetReference,
+    DestinationPubSubSubscription,
     DiscoveryType,
     GetDataExchangeRequest,
     GetListingRequest,
@@ -55,6 +56,7 @@
     RefreshSubscriptionResponse,
     RevokeSubscriptionRequest,
     RevokeSubscriptionResponse,
+    SharedResourceType,
     SharingEnvironmentConfig,
     SubscribeDataExchangeRequest,
     SubscribeDataExchangeResponse,
@@ -64,6 +66,17 @@
     UpdateDataExchangeRequest,
     UpdateListingRequest,
 )
+from google.cloud.bigquery_analyticshub_v1.types.pubsub import (
+    BigQueryConfig,
+    CloudStorageConfig,
+    DeadLetterPolicy,
+    ExpirationPolicy,
+    JavaScriptUDF,
+    MessageTransform,
+    PubSubSubscription,
+    PushConfig,
+    RetryPolicy,
+)
 
 __all__ = (
     "AnalyticsHubServiceClient",
@@ -77,6 +90,7 @@
     "DeleteSubscriptionRequest",
     "DestinationDataset",
     "DestinationDatasetReference",
+    "DestinationPubSubSubscription",
     "GetDataExchangeRequest",
     "GetListingRequest",
     "GetSubscriptionRequest",
@@ -106,4 +120,14 @@
     "UpdateDataExchangeRequest",
     "UpdateListingRequest",
     "DiscoveryType",
+    "SharedResourceType",
+    "BigQueryConfig",
+    "CloudStorageConfig",
+    "DeadLetterPolicy",
+    "ExpirationPolicy",
+    "JavaScriptUDF",
+    "MessageTransform",
+    "PubSubSubscription",
+    "PushConfig",
+    "RetryPolicy",
 )

packages/google-cloud-bigquery-analyticshub/google/cloud/bigquery_analyticshub_v1/__init__.py

@@ -32,6 +32,7 @@
     DeleteSubscriptionRequest,
     DestinationDataset,
     DestinationDatasetReference,
+    DestinationPubSubSubscription,
     DiscoveryType,
     GetDataExchangeRequest,
     GetListingRequest,
@@ -53,6 +54,7 @@
     RefreshSubscriptionResponse,
     RevokeSubscriptionRequest,
     RevokeSubscriptionResponse,
+    SharedResourceType,
     SharingEnvironmentConfig,
     SubscribeDataExchangeRequest,
     SubscribeDataExchangeResponse,
@@ -62,23 +64,40 @@
     UpdateDataExchangeRequest,
     UpdateListingRequest,
 )
+from .types.pubsub import (
+    BigQueryConfig,
+    CloudStorageConfig,
+    DeadLetterPolicy,
+    ExpirationPolicy,
+    JavaScriptUDF,
+    MessageTransform,
+    PubSubSubscription,
+    PushConfig,
+    RetryPolicy,
+)
 
 __all__ = (
     "AnalyticsHubServiceAsyncClient",
     "AnalyticsHubServiceClient",
+    "BigQueryConfig",
+    "CloudStorageConfig",
     "CreateDataExchangeRequest",
     "CreateListingRequest",
     "DataExchange",
     "DataProvider",
+    "DeadLetterPolicy",
     "DeleteDataExchangeRequest",
     "DeleteListingRequest",
     "DeleteSubscriptionRequest",
     "DestinationDataset",
     "DestinationDatasetReference",
+    "DestinationPubSubSubscription",
     "DiscoveryType",
+    "ExpirationPolicy",
     "GetDataExchangeRequest",
     "GetListingRequest",
     "GetSubscriptionRequest",
+    "JavaScriptUDF",
     "ListDataExchangesRequest",
     "ListDataExchangesResponse",
     "ListListingsRequest",
@@ -90,12 +109,17 @@
     "ListSubscriptionsRequest",
     "ListSubscriptionsResponse",
     "Listing",
+    "MessageTransform",
     "OperationMetadata",
+    "PubSubSubscription",
     "Publisher",
+    "PushConfig",
     "RefreshSubscriptionRequest",
     "RefreshSubscriptionResponse",
+    "RetryPolicy",
     "RevokeSubscriptionRequest",
     "RevokeSubscriptionResponse",
+    "SharedResourceType",
     "SharingEnvironmentConfig",
     "SubscribeDataExchangeRequest",
     "SubscribeDataExchangeResponse",

packages/google-cloud-bigquery-analyticshub/google/cloud/bigquery_analyticshub_v1/services/analytics_hub_service/async_client.py

@@ -102,6 +102,8 @@ class AnalyticsHubServiceAsyncClient:
     )
     table_path = staticmethod(AnalyticsHubServiceClient.table_path)
     parse_table_path = staticmethod(AnalyticsHubServiceClient.parse_table_path)
+    topic_path = staticmethod(AnalyticsHubServiceClient.topic_path)
+    parse_topic_path = staticmethod(AnalyticsHubServiceClient.parse_topic_path)
     common_billing_account_path = staticmethod(
         AnalyticsHubServiceClient.common_billing_account_path
     )
@@ -1776,8 +1778,8 @@ async def subscribe_data_exchange(
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ) -> operation_async.AsyncOperation:
-        r"""Creates a Subscription to a Data Exchange. This is a
-        long-running operation as it will create one or more
+        r"""Creates a Subscription to a Data Clean Room. This is
+        a long-running operation as it will create one or more
         linked datasets.
 
         .. code-block:: python
@@ -2461,7 +2463,7 @@ async def sample_revoke_subscription():
         Returns:
             google.cloud.bigquery_analyticshub_v1.types.RevokeSubscriptionResponse:
                 Message for response when you revoke
-                a subscription.
+                a subscription. Empty for now.
 
         """
         # Create or coerce a protobuf request object.

packages/google-cloud-bigquery-analyticshub/google/cloud/bigquery_analyticshub_v1/services/analytics_hub_service/client.py

@@ -316,6 +316,23 @@ def parse_table_path(path: str) -> Dict[str, str]:
         )
         return m.groupdict() if m else {}
 
+    @staticmethod
+    def topic_path(
+        project: str,
+        topic: str,
+    ) -> str:
+        """Returns a fully-qualified topic string."""
+        return "projects/{project}/topics/{topic}".format(
+            project=project,
+            topic=topic,
+        )
+
+    @staticmethod
+    def parse_topic_path(path: str) -> Dict[str, str]:
+        """Parses a topic path into its component segments."""
+        m = re.match(r"^projects/(?P<project>.+?)/topics/(?P<topic>.+?)$", path)
+        return m.groupdict() if m else {}
+
     @staticmethod
     def common_billing_account_path(
         billing_account: str,
@@ -2235,8 +2252,8 @@ def subscribe_data_exchange(
         timeout: Union[float, object] = gapic_v1.method.DEFAULT,
         metadata: Sequence[Tuple[str, Union[str, bytes]]] = (),
     ) -> operation.Operation:
-        r"""Creates a Subscription to a Data Exchange. This is a
-        long-running operation as it will create one or more
+        r"""Creates a Subscription to a Data Clean Room. This is
+        a long-running operation as it will create one or more
         linked datasets.
 
         .. code-block:: python
@@ -2907,7 +2924,7 @@ def sample_revoke_subscription():
         Returns:
             google.cloud.bigquery_analyticshub_v1.types.RevokeSubscriptionResponse:
                 Message for response when you revoke
-                a subscription.
+                a subscription. Empty for now.
 
         """
         # Create or coerce a protobuf request object.

packages/google-cloud-bigquery-analyticshub/google/cloud/bigquery_analyticshub_v1/services/analytics_hub_service/transports/grpc.py

@@ -684,8 +684,8 @@ def subscribe_data_exchange(
     ]:
         r"""Return a callable for the subscribe data exchange method over gRPC.
 
-        Creates a Subscription to a Data Exchange. This is a
-        long-running operation as it will create one or more
+        Creates a Subscription to a Data Clean Room. This is
+        a long-running operation as it will create one or more
         linked datasets.
 
         Returns:

packages/google-cloud-bigquery-analyticshub/google/cloud/bigquery_analyticshub_v1/services/analytics_hub_service/transports/grpc_asyncio.py

@@ -699,8 +699,8 @@ def subscribe_data_exchange(
     ]:
         r"""Return a callable for the subscribe data exchange method over gRPC.
 
-        Creates a Subscription to a Data Exchange. This is a
-        long-running operation as it will create one or more
+        Creates a Subscription to a Data Clean Room. This is
+        a long-running operation as it will create one or more
         linked datasets.
 
         Returns:

packages/google-cloud-bigquery-analyticshub/google/cloud/bigquery_analyticshub_v1/types/__init__.py

@@ -23,6 +23,7 @@
     DeleteSubscriptionRequest,
     DestinationDataset,
     DestinationDatasetReference,
+    DestinationPubSubSubscription,
     DiscoveryType,
     GetDataExchangeRequest,
     GetListingRequest,
@@ -44,6 +45,7 @@
     RefreshSubscriptionResponse,
     RevokeSubscriptionRequest,
     RevokeSubscriptionResponse,
+    SharedResourceType,
     SharingEnvironmentConfig,
     SubscribeDataExchangeRequest,
     SubscribeDataExchangeResponse,
@@ -53,6 +55,17 @@
     UpdateDataExchangeRequest,
     UpdateListingRequest,
 )
+from .pubsub import (
+    BigQueryConfig,
+    CloudStorageConfig,
+    DeadLetterPolicy,
+    ExpirationPolicy,
+    JavaScriptUDF,
+    MessageTransform,
+    PubSubSubscription,
+    PushConfig,
+    RetryPolicy,
+)
 
 __all__ = (
     "CreateDataExchangeRequest",
@@ -64,6 +77,7 @@
     "DeleteSubscriptionRequest",
     "DestinationDataset",
     "DestinationDatasetReference",
+    "DestinationPubSubSubscription",
     "GetDataExchangeRequest",
     "GetListingRequest",
     "GetSubscriptionRequest",
@@ -93,4 +107,14 @@
     "UpdateDataExchangeRequest",
     "UpdateListingRequest",
     "DiscoveryType",
+    "SharedResourceType",
+    "BigQueryConfig",
+    "CloudStorageConfig",
+    "DeadLetterPolicy",
+    "ExpirationPolicy",
+    "JavaScriptUDF",
+    "MessageTransform",
+    "PubSubSubscription",
+    "PushConfig",
+    "RetryPolicy",
 )