Package Methods (2.31.0)

Summary of entries of Methods for pubsub.

google.cloud.pubsub_v1.publisher.client.Client

Client(
 batch_settings: typing.Union[
 google.cloud.pubsub_v1.types.BatchSettings, typing.Sequence
 ] = (),
 publisher_options: typing.Union[
 google.cloud.pubsub_v1.types.PublisherOptions, typing.Sequence
 ] = (),
 **kwargs: typing.Any
)

Instantiates the publisher client.

See more: google.cloud.pubsub_v1.publisher.client.Client

google.cloud.pubsub_v1.publisher.client.Client.__exit__

__exit__(type, value, traceback)

Releases underlying transport's resources.

See more: google.cloud.pubsub_v1.publisher.client.Client.exit

google.cloud.pubsub_v1.publisher.client.Client.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.pubsub_v1.publisher.client.Client.common_billing_account_path

google.cloud.pubsub_v1.publisher.client.Client.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.pubsub_v1.publisher.client.Client.common_folder_path

google.cloud.pubsub_v1.publisher.client.Client.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.pubsub_v1.publisher.client.Client.common_location_path

google.cloud.pubsub_v1.publisher.client.Client.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.pubsub_v1.publisher.client.Client.common_organization_path

google.cloud.pubsub_v1.publisher.client.Client.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.pubsub_v1.publisher.client.Client.common_project_path

google.cloud.pubsub_v1.publisher.client.Client.create_topic

create_topic(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.Topic, dict]
 ] = None,
 *,
 name: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[
 int,
 float,
 google.api_core.timeout.ConstantTimeout,
 google.api_core.timeout.ExponentialTimeout,
 ] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.Topic

Creates the given topic with the given name.

See more: google.cloud.pubsub_v1.publisher.client.Client.create_topic

google.cloud.pubsub_v1.publisher.client.Client.delete_topic

delete_topic(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.DeleteTopicRequest, dict]
 ] = None,
 *,
 topic: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[
 int,
 float,
 google.api_core.timeout.ConstantTimeout,
 google.api_core.timeout.ExponentialTimeout,
 ] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> None

Deletes the topic with the given name.

See more: google.cloud.pubsub_v1.publisher.client.Client.delete_topic

google.cloud.pubsub_v1.publisher.client.Client.detach_subscription

detach_subscription(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.DetachSubscriptionRequest, dict]
 ] = None,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[
 int,
 float,
 google.api_core.timeout.ConstantTimeout,
 google.api_core.timeout.ExponentialTimeout,
 ] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.DetachSubscriptionResponse

Detaches a subscription from this topic.

See more: google.cloud.pubsub_v1.publisher.client.Client.detach_subscription

google.cloud.pubsub_v1.publisher.client.Client.ensure_cleanup_and_commit_timer_runs

ensure_cleanup_and_commit_timer_runs() -> None

Ensure a cleanup/commit timer thread is running.

See more: google.cloud.pubsub_v1.publisher.client.Client.ensure_cleanup_and_commit_timer_runs

google.cloud.pubsub_v1.publisher.client.Client.from_service_account_file

from_service_account_file(
 filename: str,
 batch_settings: typing.Union[
 google.cloud.pubsub_v1.types.BatchSettings, typing.Sequence
 ] = (),
 **kwargs: typing.Any
) -> google.cloud.pubsub_v1.publisher.client.Client

Creates an instance of this client using the provided credentials file.

See more: google.cloud.pubsub_v1.publisher.client.Client.from_service_account_file

google.cloud.pubsub_v1.publisher.client.Client.from_service_account_info

from_service_account_info(info: dict, *args, **kwargs)

Creates an instance of this client using the provided credentials info.

See more: google.cloud.pubsub_v1.publisher.client.Client.from_service_account_info

google.cloud.pubsub_v1.publisher.client.Client.from_service_account_json

from_service_account_json(
 filename: str,
 batch_settings: typing.Union[
 google.cloud.pubsub_v1.types.BatchSettings, typing.Sequence
 ] = (),
 **kwargs: typing.Any
) -> google.cloud.pubsub_v1.publisher.client.Client

Creates an instance of this client using the provided credentials file.

See more: google.cloud.pubsub_v1.publisher.client.Client.from_service_account_json

google.cloud.pubsub_v1.publisher.client.Client.get_iam_policy

get_iam_policy(
 request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[
 int,
 float,
 google.api_core.timeout.ConstantTimeout,
 google.api_core.timeout.ExponentialTimeout,
 ] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.pubsub_v1.publisher.client.Client.get_iam_policy

google.cloud.pubsub_v1.publisher.client.Client.get_mtls_endpoint_and_cert_source

get_mtls_endpoint_and_cert_source(
 client_options: typing.Optional[
 google.api_core.client_options.ClientOptions
 ] = None,
)

google.cloud.pubsub_v1.publisher.client.Client.get_topic

get_topic(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.GetTopicRequest, dict]
 ] = None,
 *,
 topic: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[
 int,
 float,
 google.api_core.timeout.ConstantTimeout,
 google.api_core.timeout.ExponentialTimeout,
 ] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.Topic

Gets the configuration of a topic.

See more: google.cloud.pubsub_v1.publisher.client.Client.get_topic

google.cloud.pubsub_v1.publisher.client.Client.list_topic_snapshots

list_topic_snapshots(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.ListTopicSnapshotsRequest, dict]
 ] = None,
 *,
 topic: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[
 int,
 float,
 google.api_core.timeout.ConstantTimeout,
 google.api_core.timeout.ExponentialTimeout,
 ] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.pubsub_v1.services.publisher.pagers.ListTopicSnapshotsPager

Lists the names of the snapshots on this topic.

See more: google.cloud.pubsub_v1.publisher.client.Client.list_topic_snapshots

google.cloud.pubsub_v1.publisher.client.Client.list_topic_subscriptions

list_topic_subscriptions(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.ListTopicSubscriptionsRequest, dict]
 ] = None,
 *,
 topic: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[
 int,
 float,
 google.api_core.timeout.ConstantTimeout,
 google.api_core.timeout.ExponentialTimeout,
 ] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.pubsub_v1.services.publisher.pagers.ListTopicSubscriptionsPager

Lists the names of the attached subscriptions on this topic.

See more: google.cloud.pubsub_v1.publisher.client.Client.list_topic_subscriptions

google.cloud.pubsub_v1.publisher.client.Client.list_topics

list_topics(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.ListTopicsRequest, dict]
 ] = None,
 *,
 project: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[
 int,
 float,
 google.api_core.timeout.ConstantTimeout,
 google.api_core.timeout.ExponentialTimeout,
 ] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.pubsub_v1.services.publisher.pagers.ListTopicsPager

google.cloud.pubsub_v1.publisher.client.Client.parse_common_billing_account_path

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

Parse a billing_account path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_common_billing_account_path

google.cloud.pubsub_v1.publisher.client.Client.parse_common_folder_path

parse_common_folder_path(path: str) -> typing.Dict[str, str]

Parse a folder path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_common_folder_path

google.cloud.pubsub_v1.publisher.client.Client.parse_common_location_path

parse_common_location_path(path: str) -> typing.Dict[str, str]

Parse a location path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_common_location_path

google.cloud.pubsub_v1.publisher.client.Client.parse_common_organization_path

parse_common_organization_path(path: str) -> typing.Dict[str, str]

Parse a organization path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_common_organization_path

google.cloud.pubsub_v1.publisher.client.Client.parse_common_project_path

parse_common_project_path(path: str) -> typing.Dict[str, str]

Parse a project path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_common_project_path

google.cloud.pubsub_v1.publisher.client.Client.parse_schema_path

parse_schema_path(path: str) -> typing.Dict[str, str]

Parses a schema path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_schema_path

google.cloud.pubsub_v1.publisher.client.Client.parse_subscription_path

parse_subscription_path(path: str) -> typing.Dict[str, str]

Parses a subscription path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_subscription_path

google.cloud.pubsub_v1.publisher.client.Client.parse_topic_path

parse_topic_path(path: str) -> typing.Dict[str, str]

Parses a topic path into its component segments.

See more: google.cloud.pubsub_v1.publisher.client.Client.parse_topic_path

google.cloud.pubsub_v1.publisher.client.Client.publish

publish(
 topic: str,
 data: bytes,
 ordering_key: str = "",
 retry: OptionalRetry = _MethodDefault._DEFAULT_VALUE,
 timeout: types.OptionalTimeout = _MethodDefault._DEFAULT_VALUE,
 **attrs: typing.Union[bytes, str]
) -> pubsub_v1.publisher.futures.Future

Publish a single message.

See more: google.cloud.pubsub_v1.publisher.client.Client.publish

google.cloud.pubsub_v1.publisher.client.Client.resume_publish

resume_publish(topic: str, ordering_key: str) -> None

Resume publish on an ordering key that has had unrecoverable errors.

See more: google.cloud.pubsub_v1.publisher.client.Client.resume_publish

google.cloud.pubsub_v1.publisher.client.Client.schema_path

schema_path(project: str, schema: str) -> str

Returns a fully-qualified schema string.

See more: google.cloud.pubsub_v1.publisher.client.Client.schema_path

google.cloud.pubsub_v1.publisher.client.Client.set_iam_policy

set_iam_policy(
 request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[
 int,
 float,
 google.api_core.timeout.ConstantTimeout,
 google.api_core.timeout.ExponentialTimeout,
 ] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.pubsub_v1.publisher.client.Client.set_iam_policy

google.cloud.pubsub_v1.publisher.client.Client.stop

stop() -> None

Immediately publish all outstanding messages.

See more: google.cloud.pubsub_v1.publisher.client.Client.stop

google.cloud.pubsub_v1.publisher.client.Client.subscription_path

subscription_path(project: str, subscription: str) -> str

Returns a fully-qualified subscription string.

See more: google.cloud.pubsub_v1.publisher.client.Client.subscription_path

google.cloud.pubsub_v1.publisher.client.Client.test_iam_permissions

test_iam_permissions(
 request: typing.Optional[
 google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
 ] = None,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[
 int,
 float,
 google.api_core.timeout.ConstantTimeout,
 google.api_core.timeout.ExponentialTimeout,
 ] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.pubsub_v1.publisher.client.Client.test_iam_permissions

google.cloud.pubsub_v1.publisher.client.Client.topic_path

topic_path(project: str, topic: str) -> str

Returns a fully-qualified topic string.

See more: google.cloud.pubsub_v1.publisher.client.Client.topic_path

google.cloud.pubsub_v1.publisher.client.Client.update_topic

update_topic(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.UpdateTopicRequest, dict]
 ] = None,
 *,
 topic: typing.Optional[google.cloud.pubsub_v1.types.Topic] = None,
 update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[
 int,
 float,
 google.api_core.timeout.ConstantTimeout,
 google.api_core.timeout.ExponentialTimeout,
 ] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.Topic

Updates an existing topic by updating the fields specified in the update mask.

See more: google.cloud.pubsub_v1.publisher.client.Client.update_topic

google.cloud.pubsub_v1.publisher.futures.Future

Future()

Initializes the future.

See more: google.cloud.pubsub_v1.publisher.futures.Future

google.cloud.pubsub_v1.publisher.futures.Future.add_done_callback

add_done_callback(
 callback: typing.Callable[[pubsub_v1.publisher.futures.Future], typing.Any],
) -> None

Attach a callable that will be called when the future finishes.

See more: google.cloud.pubsub_v1.publisher.futures.Future.add_done_callback

google.cloud.pubsub_v1.publisher.futures.Future.cancel

cancel() -> bool

Actions in Pub/Sub generally may not be canceled.

See more: google.cloud.pubsub_v1.publisher.futures.Future.cancel

google.cloud.pubsub_v1.publisher.futures.Future.cancelled

cancelled() -> bool

Actions in Pub/Sub generally may not be canceled.

See more: google.cloud.pubsub_v1.publisher.futures.Future.cancelled

google.cloud.pubsub_v1.publisher.futures.Future.done

done()

Return True if the future was cancelled or finished executing.

See more: google.cloud.pubsub_v1.publisher.futures.Future.done

google.cloud.pubsub_v1.publisher.futures.Future.exception

exception(timeout=None)

Return the exception raised by the call that the future represents.

See more: google.cloud.pubsub_v1.publisher.futures.Future.exception

google.cloud.pubsub_v1.publisher.futures.Future.result

result(timeout: typing.Optional[typing.Union[int, float]] = None) -> str

Return the message ID or raise an exception.

See more: google.cloud.pubsub_v1.publisher.futures.Future.result

google.cloud.pubsub_v1.publisher.futures.Future.running

running() -> bool

Return True if the associated Pub/Sub action has not yet completed.

See more: google.cloud.pubsub_v1.publisher.futures.Future.running

google.cloud.pubsub_v1.publisher.futures.Future.set_exception

set_exception(exception: typing.Optional[BaseException])

Set the result of the future as being the given exception.

See more: google.cloud.pubsub_v1.publisher.futures.Future.set_exception

google.cloud.pubsub_v1.publisher.futures.Future.set_result

set_result(result: typing.Any)

Set the return value of work associated with the future.

See more: google.cloud.pubsub_v1.publisher.futures.Future.set_result

google.cloud.pubsub_v1.publisher.futures.Future.set_running_or_notify_cancel

set_running_or_notify_cancel() -> typing.NoReturn

Mark the future as running or process any cancel notifications.

See more: google.cloud.pubsub_v1.publisher.futures.Future.set_running_or_notify_cancel

google.cloud.pubsub_v1.subscriber.client.Client

Client(
 subscriber_options: typing.Union[
 google.cloud.pubsub_v1.types.SubscriberOptions, typing.Sequence
 ] = (),
 **kwargs: typing.Any
)

Instantiates the subscriber client.

See more: google.cloud.pubsub_v1.subscriber.client.Client

google.cloud.pubsub_v1.subscriber.client.Client.acknowledge

acknowledge(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.AcknowledgeRequest, dict]
 ] = None,
 *,
 subscription: typing.Optional[str] = None,
 ack_ids: typing.Optional[typing.MutableSequence[str]] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> None

Acknowledges the messages associated with the ack_ids in the AcknowledgeRequest.

See more: google.cloud.pubsub_v1.subscriber.client.Client.acknowledge

google.cloud.pubsub_v1.subscriber.client.Client.close

close() -> None

Close the underlying channel to release socket resources.

See more: google.cloud.pubsub_v1.subscriber.client.Client.close

google.cloud.pubsub_v1.subscriber.client.Client.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

Returns a fully-qualified billing_account string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.common_billing_account_path

google.cloud.pubsub_v1.subscriber.client.Client.common_folder_path

common_folder_path(folder: str) -> str

Returns a fully-qualified folder string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.common_folder_path

google.cloud.pubsub_v1.subscriber.client.Client.common_location_path

common_location_path(project: str, location: str) -> str

Returns a fully-qualified location string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.common_location_path

google.cloud.pubsub_v1.subscriber.client.Client.common_organization_path

common_organization_path(organization: str) -> str

Returns a fully-qualified organization string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.common_organization_path

google.cloud.pubsub_v1.subscriber.client.Client.common_project_path

common_project_path(project: str) -> str

Returns a fully-qualified project string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.common_project_path

google.cloud.pubsub_v1.subscriber.client.Client.create_snapshot

create_snapshot(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.CreateSnapshotRequest, dict]
 ] = None,
 *,
 name: typing.Optional[str] = None,
 subscription: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.Snapshot

Creates a snapshot from the requested subscription.

See more: google.cloud.pubsub_v1.subscriber.client.Client.create_snapshot

google.cloud.pubsub_v1.subscriber.client.Client.create_subscription

create_subscription(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.Subscription, dict]
 ] = None,
 *,
 name: typing.Optional[str] = None,
 topic: typing.Optional[str] = None,
 push_config: typing.Optional[google.cloud.pubsub_v1.types.PushConfig] = None,
 ack_deadline_seconds: typing.Optional[int] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.Subscription

Creates a subscription to a given topic.

See more: google.cloud.pubsub_v1.subscriber.client.Client.create_subscription

google.cloud.pubsub_v1.subscriber.client.Client.delete_snapshot

delete_snapshot(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.DeleteSnapshotRequest, dict]
 ] = None,
 *,
 snapshot: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> None

google.cloud.pubsub_v1.subscriber.client.Client.delete_subscription

delete_subscription(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.DeleteSubscriptionRequest, dict]
 ] = None,
 *,
 subscription: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> None

Deletes an existing subscription.

See more: google.cloud.pubsub_v1.subscriber.client.Client.delete_subscription

google.cloud.pubsub_v1.subscriber.client.Client.from_service_account_file

from_service_account_file(
 filename: str, **kwargs: typing.Any
) -> google.cloud.pubsub_v1.subscriber.client.Client

Creates an instance of this client using the provided credentials file.

See more: google.cloud.pubsub_v1.subscriber.client.Client.from_service_account_file

google.cloud.pubsub_v1.subscriber.client.Client.from_service_account_info

from_service_account_info(info: dict, *args, **kwargs)

Creates an instance of this client using the provided credentials info.

See more: google.cloud.pubsub_v1.subscriber.client.Client.from_service_account_info

google.cloud.pubsub_v1.subscriber.client.Client.from_service_account_json

from_service_account_json(
 filename: str, **kwargs: typing.Any
) -> google.cloud.pubsub_v1.subscriber.client.Client

Creates an instance of this client using the provided credentials file.

See more: google.cloud.pubsub_v1.subscriber.client.Client.from_service_account_json

google.cloud.pubsub_v1.subscriber.client.Client.get_iam_policy

get_iam_policy(
 request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.Policy

Gets the IAM access control policy for a function.

See more: google.cloud.pubsub_v1.subscriber.client.Client.get_iam_policy

google.cloud.pubsub_v1.subscriber.client.Client.get_mtls_endpoint_and_cert_source

get_mtls_endpoint_and_cert_source(
 client_options: typing.Optional[
 google.api_core.client_options.ClientOptions
 ] = None,
)

google.cloud.pubsub_v1.subscriber.client.Client.get_snapshot

get_snapshot(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.GetSnapshotRequest, dict]
 ] = None,
 *,
 snapshot: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.Snapshot

Gets the configuration details of a snapshot.

See more: google.cloud.pubsub_v1.subscriber.client.Client.get_snapshot

google.cloud.pubsub_v1.subscriber.client.Client.get_subscription

get_subscription(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.GetSubscriptionRequest, dict]
 ] = None,
 *,
 subscription: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.Subscription

Gets the configuration details of a subscription.

See more: google.cloud.pubsub_v1.subscriber.client.Client.get_subscription

google.cloud.pubsub_v1.subscriber.client.Client.list_snapshots

list_snapshots(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.ListSnapshotsRequest, dict]
 ] = None,
 *,
 project: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.pubsub_v1.services.subscriber.pagers.ListSnapshotsPager

google.cloud.pubsub_v1.subscriber.client.Client.list_subscriptions

list_subscriptions(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.ListSubscriptionsRequest, dict]
 ] = None,
 *,
 project: typing.Optional[str] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.pubsub_v1.services.subscriber.pagers.ListSubscriptionsPager

google.cloud.pubsub_v1.subscriber.client.Client.modify_ack_deadline

modify_ack_deadline(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.ModifyAckDeadlineRequest, dict]
 ] = None,
 *,
 subscription: typing.Optional[str] = None,
 ack_ids: typing.Optional[typing.MutableSequence[str]] = None,
 ack_deadline_seconds: typing.Optional[int] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> None

Modifies the ack deadline for a specific message.

See more: google.cloud.pubsub_v1.subscriber.client.Client.modify_ack_deadline

google.cloud.pubsub_v1.subscriber.client.Client.modify_push_config

modify_push_config(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.ModifyPushConfigRequest, dict]
 ] = None,
 *,
 subscription: typing.Optional[str] = None,
 push_config: typing.Optional[google.cloud.pubsub_v1.types.PushConfig] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> None

Modifies the PushConfig for a specified subscription.

See more: google.cloud.pubsub_v1.subscriber.client.Client.modify_push_config

google.cloud.pubsub_v1.subscriber.client.Client.parse_common_billing_account_path

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

Parse a billing_account path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_common_billing_account_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_common_folder_path

parse_common_folder_path(path: str) -> typing.Dict[str, str]

Parse a folder path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_common_folder_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_common_location_path

parse_common_location_path(path: str) -> typing.Dict[str, str]

Parse a location path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_common_location_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_common_organization_path

parse_common_organization_path(path: str) -> typing.Dict[str, str]

Parse a organization path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_common_organization_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_common_project_path

parse_common_project_path(path: str) -> typing.Dict[str, str]

Parse a project path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_common_project_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_snapshot_path

parse_snapshot_path(path: str) -> typing.Dict[str, str]

Parses a snapshot path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_snapshot_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_subscription_path

parse_subscription_path(path: str) -> typing.Dict[str, str]

Parses a subscription path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_subscription_path

google.cloud.pubsub_v1.subscriber.client.Client.parse_topic_path

parse_topic_path(path: str) -> typing.Dict[str, str]

Parses a topic path into its component segments.

See more: google.cloud.pubsub_v1.subscriber.client.Client.parse_topic_path

google.cloud.pubsub_v1.subscriber.client.Client.pull

pull(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.PullRequest, dict]
 ] = None,
 *,
 subscription: typing.Optional[str] = None,
 return_immediately: typing.Optional[bool] = None,
 max_messages: typing.Optional[int] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.PullResponse

Pulls messages from the server.

See more: google.cloud.pubsub_v1.subscriber.client.Client.pull

google.cloud.pubsub_v1.subscriber.client.Client.seek

seek(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.SeekRequest, dict]
 ] = None,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.SeekResponse

Seeks an existing subscription to a point in time or to a given snapshot, whichever is provided in the request.

See more: google.cloud.pubsub_v1.subscriber.client.Client.seek

google.cloud.pubsub_v1.subscriber.client.Client.set_iam_policy

set_iam_policy(
 request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.policy_pb2.Policy

Sets the IAM access control policy on the specified function.

See more: google.cloud.pubsub_v1.subscriber.client.Client.set_iam_policy

google.cloud.pubsub_v1.subscriber.client.Client.snapshot_path

snapshot_path(project: str, snapshot: str) -> str

Returns a fully-qualified snapshot string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.snapshot_path

google.cloud.pubsub_v1.subscriber.client.Client.streaming_pull

streaming_pull(
 requests: typing.Optional[
 typing.Iterator[google.cloud.pubsub_v1.types.StreamingPullRequest]
 ] = None,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> typing.Iterable[google.cloud.pubsub_v1.types.StreamingPullResponse]

Establishes a stream with the server, which sends messages down to the client.

See more: google.cloud.pubsub_v1.subscriber.client.Client.streaming_pull

google.cloud.pubsub_v1.subscriber.client.Client.subscribe

subscribe(
 subscription: str,
 callback: typing.Callable[[subscriber.message.Message], typing.Any],
 flow_control: typing.Union[
 google.cloud.pubsub_v1.types.FlowControl, typing.Sequence
 ] = (),
 scheduler: typing.Optional[subscriber.scheduler.ThreadScheduler] = None,
 use_legacy_flow_control: bool = False,
 await_callbacks_on_shutdown: bool = False,
) -> google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture

Asynchronously start receiving messages on a given subscription.

See more: google.cloud.pubsub_v1.subscriber.client.Client.subscribe

google.cloud.pubsub_v1.subscriber.client.Client.subscription_path

subscription_path(project: str, subscription: str) -> str

Returns a fully-qualified subscription string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.subscription_path

google.cloud.pubsub_v1.subscriber.client.Client.test_iam_permissions

test_iam_permissions(
 request: typing.Optional[
 google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest
 ] = None,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponse

Tests the specified IAM permissions against the IAM access control policy for a function.

See more: google.cloud.pubsub_v1.subscriber.client.Client.test_iam_permissions

google.cloud.pubsub_v1.subscriber.client.Client.topic_path

topic_path(project: str, topic: str) -> str

Returns a fully-qualified topic string.

See more: google.cloud.pubsub_v1.subscriber.client.Client.topic_path

google.cloud.pubsub_v1.subscriber.client.Client.update_snapshot

update_snapshot(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.UpdateSnapshotRequest, dict]
 ] = None,
 *,
 snapshot: typing.Optional[google.cloud.pubsub_v1.types.Snapshot] = None,
 update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.Snapshot

Updates an existing snapshot by updating the fields specified in the update mask.

See more: google.cloud.pubsub_v1.subscriber.client.Client.update_snapshot

google.cloud.pubsub_v1.subscriber.client.Client.update_subscription

update_subscription(
 request: typing.Optional[
 typing.Union[google.cloud.pubsub_v1.types.UpdateSubscriptionRequest, dict]
 ] = None,
 *,
 subscription: typing.Optional[google.cloud.pubsub_v1.types.Subscription] = None,
 update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
) -> google.cloud.pubsub_v1.types.Subscription

Updates an existing subscription by updating the fields specified in the update mask.

See more: google.cloud.pubsub_v1.subscriber.client.Client.update_subscription

google.cloud.pubsub_v1.subscriber.futures.Future

Future()

Initializes the future.

See more: google.cloud.pubsub_v1.subscriber.futures.Future

google.cloud.pubsub_v1.subscriber.futures.Future.add_done_callback

add_done_callback(fn)

Attaches a callable that will be called when the future finishes.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.add_done_callback

google.cloud.pubsub_v1.subscriber.futures.Future.cancel

cancel() -> bool

Actions in Pub/Sub generally may not be canceled.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.cancel

google.cloud.pubsub_v1.subscriber.futures.Future.cancelled

cancelled() -> bool

Actions in Pub/Sub generally may not be canceled.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.cancelled

google.cloud.pubsub_v1.subscriber.futures.Future.done

done()

Return True if the future was cancelled or finished executing.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.done

google.cloud.pubsub_v1.subscriber.futures.Future.exception

exception(timeout=None)

Return the exception raised by the call that the future represents.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.exception

google.cloud.pubsub_v1.subscriber.futures.Future.result

result(
 timeout: typing.Optional[typing.Union[int, float]] = None,
) -> google.cloud.pubsub_v1.subscriber.exceptions.AcknowledgeStatus

Return a success code or raise an exception.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.result

google.cloud.pubsub_v1.subscriber.futures.Future.running

running() -> bool

Return True if the associated Pub/Sub action has not yet completed.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.running

google.cloud.pubsub_v1.subscriber.futures.Future.set_exception

set_exception(exception: typing.Optional[BaseException])

Set the result of the future as being the given exception.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.set_exception

google.cloud.pubsub_v1.subscriber.futures.Future.set_result

set_result(result: typing.Any)

Set the return value of work associated with the future.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.set_result

google.cloud.pubsub_v1.subscriber.futures.Future.set_running_or_notify_cancel

set_running_or_notify_cancel() -> typing.NoReturn

Mark the future as running or process any cancel notifications.

See more: google.cloud.pubsub_v1.subscriber.futures.Future.set_running_or_notify_cancel

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture

StreamingPullFuture(manager: StreamingPullManager)

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.add_done_callback

add_done_callback(fn)

Attaches a callable that will be called when the future finishes.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.add_done_callback

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.cancel

cancel() -> bool

Stops pulling messages and shutdowns the background thread consuming messages.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.cancel

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.cancelled

cancelled() -> bool

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.done

done()

Return True if the future was cancelled or finished executing.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.done

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.exception

exception(timeout=None)

Return the exception raised by the call that the future represents.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.exception

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.result

result(timeout=None)

Return the result of the call that the future represents.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.result

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.running

running() -> bool

Return True if the associated Pub/Sub action has not yet completed.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.running

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.set_exception

set_exception(exception: typing.Optional[BaseException])

Set the result of the future as being the given exception.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.set_exception

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.set_result

set_result(result: typing.Any)

Set the return value of work associated with the future.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.set_result

google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.set_running_or_notify_cancel

set_running_or_notify_cancel() -> typing.NoReturn

Mark the future as running or process any cancel notifications.

See more: google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.set_running_or_notify_cancel

google.cloud.pubsub_v1.subscriber.message.Message

Message(message: types.PubsubMessage._meta._pb, ack_id: str, delivery_attempt: int, request_queue: queue.Queue, exactly_once_delivery_enabled_func: typing.Callable[[], bool] =

Construct the Message.

See more: google.cloud.pubsub_v1.subscriber.message.Message

google.cloud.pubsub_v1.subscriber.message.Message.ack

ack() -> None

Acknowledge the given message.

See more: google.cloud.pubsub_v1.subscriber.message.Message.ack

google.cloud.pubsub_v1.subscriber.message.Message.ack_with_response

ack_with_response() -> google.cloud.pubsub_v1.subscriber.futures.Future

google.cloud.pubsub_v1.subscriber.message.Message.drop

drop() -> None

Release the message from lease management.

See more: google.cloud.pubsub_v1.subscriber.message.Message.drop

google.cloud.pubsub_v1.subscriber.message.Message.modify_ack_deadline

modify_ack_deadline(seconds: int) -> None

Resets the deadline for acknowledgement.

See more: google.cloud.pubsub_v1.subscriber.message.Message.modify_ack_deadline

google.cloud.pubsub_v1.subscriber.message.Message.modify_ack_deadline_with_response

modify_ack_deadline_with_response(
 seconds: int,
) -> google.cloud.pubsub_v1.subscriber.futures.Future

Resets the deadline for acknowledgement and returns the response status via a future.

See more: google.cloud.pubsub_v1.subscriber.message.Message.modify_ack_deadline_with_response

google.cloud.pubsub_v1.subscriber.message.Message.nack

nack() -> None

Decline to acknowledge the given message.

See more: google.cloud.pubsub_v1.subscriber.message.Message.nack

google.cloud.pubsub_v1.subscriber.message.Message.nack_with_response

nack_with_response() -> google.cloud.pubsub_v1.subscriber.futures.Future

Decline to acknowledge the given message, returning the response status via a future.

See more: google.cloud.pubsub_v1.subscriber.message.Message.nack_with_response

google.cloud.pubsub_v1.subscriber.scheduler.Scheduler.schedule

schedule(callback: typing.Callable, *args, **kwargs) -> None

Schedule the callback to be called asynchronously.

See more: google.cloud.pubsub_v1.subscriber.scheduler.Scheduler.schedule

google.cloud.pubsub_v1.subscriber.scheduler.Scheduler.shutdown

shutdown(
 await_msg_callbacks: bool = False,
) -> typing.List[pubsub_v1.subscriber.message.Message]

Shuts down the scheduler and immediately end all pending callbacks.

See more: google.cloud.pubsub_v1.subscriber.scheduler.Scheduler.shutdown

google.cloud.pubsub_v1.subscriber.scheduler.ThreadScheduler.schedule

schedule(callback: typing.Callable, *args, **kwargs) -> None

Schedule the callback to be called asynchronously in a thread pool.

See more: google.cloud.pubsub_v1.subscriber.scheduler.ThreadScheduler.schedule

google.cloud.pubsub_v1.subscriber.scheduler.ThreadScheduler.shutdown

shutdown(
 await_msg_callbacks: bool = False,
) -> typing.List[pubsub_v1.subscriber.message.Message]

Shut down the scheduler and immediately end all pending callbacks.

See more: google.cloud.pubsub_v1.subscriber.scheduler.ThreadScheduler.shutdown

google.cloud.pubsub_v1.types.BatchSettings

BatchSettings(
 max_bytes: int = 1000000, max_latency: float = 0.01, max_messages: int = 100
)

Create new instance of BatchSettings(max_bytes, max_latency, max_messages).

See more: google.cloud.pubsub_v1.types.BatchSettings

google.cloud.pubsub_v1.types.FlowControl

FlowControl(
 max_bytes: int = 104857600,
 max_messages: int = 1000,
 max_lease_duration: float = 3600,
 min_duration_per_lease_extension: float = 0,
 max_duration_per_lease_extension: float = 0,
)

Create new instance of FlowControl(max_bytes, max_messages, max_lease_duration, min_duration_per_lease_extension, max_duration_per_lease_extension).

See more: google.cloud.pubsub_v1.types.FlowControl

google.cloud.pubsub_v1.types.PublishFlowControl

PublishFlowControl(
 message_limit: int = 1000,
 byte_limit: int = 10000000,
 limit_exceeded_behavior: google.cloud.pubsub_v1.types.LimitExceededBehavior = LimitExceededBehavior.IGNORE,
)

Create new instance of PublishFlowControl(message_limit, byte_limit, limit_exceeded_behavior).

See more: google.cloud.pubsub_v1.types.PublishFlowControl

google.cloud.pubsub_v1.types.PublisherOptions

PublisherOptions(enable_message_ordering: bool = False, flow_control: google.cloud.pubsub_v1.types.PublishFlowControl = PublishFlowControl(message_limit=1000, byte_limit=10000000, limit_exceeded_behavior=

Create new instance of PublisherOptions(enable_message_ordering, flow_control, retry, timeout, enable_open_telemetry_tracing).

See more: google.cloud.pubsub_v1.types.PublisherOptions

google.pubsub_v1.services.publisher.pagers.ListTopicSnapshotsAsyncPager

ListTopicSnapshotsAsyncPager(
 method: typing.Callable[
 [...], typing.Awaitable[google.cloud.pubsub_v1.types.ListTopicSnapshotsResponse]
 ],
 request: google.cloud.pubsub_v1.types.ListTopicSnapshotsRequest,
 response: google.cloud.pubsub_v1.types.ListTopicSnapshotsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary_async.AsyncRetry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

google.pubsub_v1.services.publisher.pagers.ListTopicSnapshotsPager

ListTopicSnapshotsPager(
 method: typing.Callable[
 [...], google.cloud.pubsub_v1.types.ListTopicSnapshotsResponse
 ],
 request: google.cloud.pubsub_v1.types.ListTopicSnapshotsRequest,
 response: google.cloud.pubsub_v1.types.ListTopicSnapshotsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

google.pubsub_v1.services.publisher.pagers.ListTopicSubscriptionsAsyncPager

ListTopicSubscriptionsAsyncPager(
 method: typing.Callable[
 [...],
 typing.Awaitable[google.cloud.pubsub_v1.types.ListTopicSubscriptionsResponse],
 ],
 request: google.cloud.pubsub_v1.types.ListTopicSubscriptionsRequest,
 response: google.cloud.pubsub_v1.types.ListTopicSubscriptionsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary_async.AsyncRetry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

google.pubsub_v1.services.publisher.pagers.ListTopicSubscriptionsPager

ListTopicSubscriptionsPager(
 method: typing.Callable[
 [...], google.cloud.pubsub_v1.types.ListTopicSubscriptionsResponse
 ],
 request: google.cloud.pubsub_v1.types.ListTopicSubscriptionsRequest,
 response: google.cloud.pubsub_v1.types.ListTopicSubscriptionsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

google.pubsub_v1.services.publisher.pagers.ListTopicsAsyncPager

ListTopicsAsyncPager(
 method: typing.Callable[
 [...], typing.Awaitable[google.cloud.pubsub_v1.types.ListTopicsResponse]
 ],
 request: google.cloud.pubsub_v1.types.ListTopicsRequest,
 response: google.cloud.pubsub_v1.types.ListTopicsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary_async.AsyncRetry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

google.pubsub_v1.services.publisher.pagers.ListTopicsPager

ListTopicsPager(
 method: typing.Callable[[...], google.cloud.pubsub_v1.types.ListTopicsResponse],
 request: google.cloud.pubsub_v1.types.ListTopicsRequest,
 response: google.cloud.pubsub_v1.types.ListTopicsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

google.pubsub_v1.services.subscriber.pagers.ListSnapshotsAsyncPager

ListSnapshotsAsyncPager(
 method: typing.Callable[
 [...], typing.Awaitable[google.cloud.pubsub_v1.types.ListSnapshotsResponse]
 ],
 request: google.cloud.pubsub_v1.types.ListSnapshotsRequest,
 response: google.cloud.pubsub_v1.types.ListSnapshotsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary_async.AsyncRetry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

google.pubsub_v1.services.subscriber.pagers.ListSnapshotsPager

ListSnapshotsPager(
 method: typing.Callable[[...], google.cloud.pubsub_v1.types.ListSnapshotsResponse],
 request: google.cloud.pubsub_v1.types.ListSnapshotsRequest,
 response: google.cloud.pubsub_v1.types.ListSnapshotsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

google.pubsub_v1.services.subscriber.pagers.ListSubscriptionsAsyncPager

ListSubscriptionsAsyncPager(
 method: typing.Callable[
 [...], typing.Awaitable[google.cloud.pubsub_v1.types.ListSubscriptionsResponse]
 ],
 request: google.cloud.pubsub_v1.types.ListSubscriptionsRequest,
 response: google.cloud.pubsub_v1.types.ListSubscriptionsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary_async.AsyncRetry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

google.pubsub_v1.services.subscriber.pagers.ListSubscriptionsPager

ListSubscriptionsPager(
 method: typing.Callable[
 [...], google.cloud.pubsub_v1.types.ListSubscriptionsResponse
 ],
 request: google.cloud.pubsub_v1.types.ListSubscriptionsRequest,
 response: google.cloud.pubsub_v1.types.ListSubscriptionsResponse,
 *,
 retry: typing.Optional[
 typing.Union[
 google.api_core.retry.retry_unary.Retry,
 google.api_core.gapic_v1.method._MethodDefault,
 ]
 ] = _MethodDefault._DEFAULT_VALUE,
 timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE,
 metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = ()
)

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2025年10月10日 UTC.