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.
|
aws_kinesis_failure
:noindex: |
google.pubsub_v1.types.IngestionFailureEvent.AwsKinesisFailureReason
Optional. Failure when ingesting from AWS Kinesis. 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.
AwsKinesisFailureReason
AwsKinesisFailureReason(mapping=None, *, ignore_unknown_fields=False, **kwargs)Failure when ingesting from an AWS Kinesis 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
AwsMskFailureReason
AwsMskFailureReason(mapping=None, *, ignore_unknown_fields=False, **kwargs)Failure when ingesting from an Amazon MSK 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
AzureEventHubsFailureReason
AzureEventHubsFailureReason(mapping=None, *, ignore_unknown_fields=False, **kwargs)Failure when ingesting from an Azure Event Hubs 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
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.
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
MessageTransformationFailureReason
MessageTransformationFailureReason(
mapping=None, *, ignore_unknown_fields=False, **kwargs
)Set when a Pub/Sub message fails to get published due to a message transformation error.
SchemaViolationReason
SchemaViolationReason(mapping=None, *, ignore_unknown_fields=False, **kwargs)Set when a Pub/Sub message fails to get published due to a schema validation violation.