Class IngestionFailureEvent (2.28.0)

Version latest

• 2.28.0 (latest)
• 2.27.3
• 2.26.1
• 2.25.2
• 2.23.1
• 2.22.0
• 2.21.5
• 2.20.3
• 2.19.8
• 2.18.4
• 2.17.1
• 2.16.1
• 2.15.2
• 2.14.1
• 2.13.12
• 2.12.1
• 2.11.1
• 2.10.0
• 2.9.0
• 2.8.0
• 2.7.1
• 2.6.1
• 2.5.0
• 2.4.2
• 2.3.0
• 2.2.0
• 2.1.0
• 2.0.0
• 1.7.2
• 1.6.1
• 1.5.0
• 1.4.3
• 1.3.1
• 1.2.0
• 1.1.0
• 1.0.2
• 0.45.0
• 0.44.0
• 0.43.0

IngestionFailureEvent(mapping=None, *, ignore_unknown_fields=False, **kwargs)

Payload of the Platform Log entry sent when a failure is encountered while ingesting.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Attributes
Name	Description
topic :noindex:	str Required. Name of the import topic. Format is: projects/{project_name}/topics/{topic_name}.
error_message :noindex:	str Required. Error details explaining why ingestion to Pub/Sub has failed.
cloud_storage_failure :noindex:	google.pubsub_v1.types.IngestionFailureEvent.CloudStorageFailure Optional. Failure when ingesting from Cloud Storage. This field is a member of oneof_ failure.
aws_msk_failure :noindex:	google.pubsub_v1.types.IngestionFailureEvent.AwsMskFailureReason Optional. Failure when ingesting from Amazon MSK. This field is a member of oneof_ failure.
azure_event_hubs_failure :noindex:	google.pubsub_v1.types.IngestionFailureEvent.AzureEventHubsFailureReason Optional. Failure when ingesting from Azure Event Hubs. This field is a member of oneof_ failure.
confluent_cloud_failure :noindex:	google.pubsub_v1.types.IngestionFailureEvent.ConfluentCloudFailureReason Optional. Failure when ingesting from Confluent Cloud. This field is a member of oneof_ failure.

Classes

ApiViolationReason

ApiViolationReason(mapping=None, *, ignore_unknown_fields=False, **kwargs)

Specifies the reason why some data may have been left out of the desired Pub/Sub message due to the API message limits (https://cloud.google.com/pubsub/quotas#resource_limits). For example, when the number of attributes is larger than 100, the number of attributes is truncated to 100 to respect the limit on the attribute count. Other attribute limits are treated similarly. When the size of the desired message would've been larger than 10MB, the message won't be published at all, and ingestion of the subsequent messages will proceed as normal.

AvroFailureReason

AvroFailureReason(mapping=None, *, ignore_unknown_fields=False, **kwargs)

Set when an Avro file is unsupported or its format is not valid. When this occurs, one or more Avro objects won't be ingested.

AwsMskFailureReason

AwsMskFailureReason(mapping=None, *, ignore_unknown_fields=False, **kwargs)

Failure when ingesting from an Amazon MSK source.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

AzureEventHubsFailureReason

AzureEventHubsFailureReason(mapping=None, *, ignore_unknown_fields=False, **kwargs)

Failure when ingesting from an Azure Event Hubs source.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

CloudStorageFailure

CloudStorageFailure(mapping=None, *, ignore_unknown_fields=False, **kwargs)

Failure when ingesting from a Cloud Storage source.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

ConfluentCloudFailureReason

ConfluentCloudFailureReason(mapping=None, *, ignore_unknown_fields=False, **kwargs)

Failure when ingesting from a Confluent Cloud source.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields