Skip to content

Commit b26c659

Browse files
authored
feat(samples): set max gRPC metadata size to 16MB in ingestion samples (#45)
Configures IngestionServiceClient with a 16MB maximum metadata size to accommodate responses with large error details, and adds the `create_client` region tag.
1 parent 62592ff commit b26c659

2 files changed

Lines changed: 22 additions & 4 deletions

File tree

‎samples/audiences/ingest_audience_members.py‎

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -202,10 +202,20 @@ def main(
202202
)
203203
)
204204

205-
# Creates a client for the ingestion service.
205+
# [START create_client]
206+
# Creates a client for the ingestion service. Increases the maximum
207+
# metadata size to 16MB to prevent RESOURCE_EXHAUSTED errors when responses
208+
# contain large error details.
209+
channel = datamanager_v1.services.ingestion_service.transports.IngestionServiceGrpcTransport.create_channel(
210+
options=[("grpc.max_metadata_size", 16 * 1024 * 1024)]
211+
)
212+
transport = datamanager_v1.services.ingestion_service.transports.IngestionServiceGrpcTransport(
213+
channel=channel
214+
)
206215
client: datamanager_v1.IngestionServiceClient = (
207-
datamanager_v1.IngestionServiceClient()
216+
datamanager_v1.IngestionServiceClient(transport=transport)
208217
)
218+
# [END create_client]
209219

210220
# Batches requests to send up to the maximum number of audience members per
211221
# request.

‎samples/events/ingest_events.py‎

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -162,9 +162,17 @@ def main(
162162
destination.linked_account.account_type = linked_account_type
163163
destination.linked_account.account_id = linked_account_id
164164

165-
# Creates a client for the ingestion service.
165+
# Creates a client for the ingestion service. Increases the maximum
166+
# metadata size to 16MB to prevent RESOURCE_EXHAUSTED errors when responses
167+
# contain large error details.
168+
channel = datamanager_v1.services.ingestion_service.transports.IngestionServiceGrpcTransport.create_channel(
169+
options=[("grpc.max_metadata_size", 16 * 1024 * 1024)]
170+
)
171+
transport = datamanager_v1.services.ingestion_service.transports.IngestionServiceGrpcTransport(
172+
channel=channel
173+
)
166174
client: datamanager_v1.IngestionServiceClient = (
167-
datamanager_v1.IngestionServiceClient()
175+
datamanager_v1.IngestionServiceClient(transport=transport)
168176
)
169177

170178
# Batches requests to send up to the maximum number of events per

0 commit comments

Comments
 (0)