class_docstr: Class to get asynchronous hook for Google Cloud PubSub.
class_docstr_tok: ["Class","to","get","asynchronous","hook","for","Google","Cloud","PubSub","."]
code: def __init__(self, project_id: str | None = None, **kwargs: Any):
      super().__init__(**kwargs)
      self.project_id = project_id
      self._client: SubscriberAsyncClient | None = None
  
imports: from __future__ import annotations
  import warnings
  from base64 import b64decode
  from functools import cached_property
  from typing import TYPE_CHECKING, Any, Sequence
  from uuid import uuid4
  from google.api_core.exceptions import AlreadyExists, GoogleAPICallError
  from google.api_core.gapic_v1.method import DEFAULT, _MethodDefault
  from google.cloud.exceptions import NotFound
  from google.cloud.pubsub_v1 import PublisherClient, SubscriberClient
  from google.pubsub_v1.services.subscriber.async_client import SubscriberAsyncClient
  from googleapiclient.errors import HttpError
  from airflow.exceptions import AirflowProviderDeprecationWarning
  from airflow.providers.google.common.consts import CLIENT_INFO
  from airflow.providers.google.common.hooks.base_google import PROVIDE_PROJECT_ID, GoogleBaseAsyncHook, GoogleBaseHook
  from airflow.version import version
label_desc: Use image node_id 1 to create a new PubSubAsyncHook object from inherited base classes: GoogleBaseAsyncHook with example: obj = PubSubAsyncHook(project_id)