RequestBodyTooLarge exception in EDS ingest for large payload.
RequestBodyTooLarge</Code><Message>The request body is too large and exceeds the maximum permissible limit
Few Details
Search Url: query_with_cursor
Airflow Logs
- QUERY BODY:
Formatted Request (truncated the conditions. I wanted to use IDs in the query, but as reported before EDS is not working with IDs):
{
"kind": "osdu:wks:master-data--Organisation:1.0.0",
"query": "Name:("TGS" OR "AGIP%20PETROLEUM"............)",
"sort": {
"field": [
"createTime"
],
"order": [
"ASC"
]
},
"limit": 2
}
- Filter criteria after: Name:("TGS" OR "AGIP%20PETROLEUM" OR "AGIP%20PETROLEUM%20CO%20INC"…………………
- Total Fetched Records: 246
- Displaying only one Sample Record : {'id': 'osdu:master-data--Organisation:TGS', 'kind': 'osdu:wks:master-data--Organisation:1.0.0', 'version': 1, 'namespace': 'osdu:wks', 'authority': 'osdu', 'source': 'wks', 'type': 'master-data--Organisation', 'acl': {'owners': ['osdu.owners@tgs.com'], 'viewers': ['osdu.viewers@tgs.com']}, 'legal': {'otherRelevantDataCountries': ['US'], 'legaltags': ['odsu-tgs-dataset'], 'status': 'compliant'}, 'tags': {'DataLakeType': '', 'UpdatedCounter': '0'}, 'createTime': '2024-11-15T15:48:16+00:00', 'createUser': 'R360customerSupport@tgs.com', 'modifyTime': '2024-11-15T15:48:16+00:00', 'modifyUser': 'R360customerSupport@tgs.com', 'data': {'OrganisationName': 'TGS', 'Source': 'TGS'}}
- ERROR: {'status': 'error', 'message': Exception('Failed to create records from the workflow. Received status: 500. Received content: b\'{"code":500,"reason":"Unable to Enqueue workflow run","message":"Status code 413, \\\\"\\xef\\xbb\\xbf<?xml version=\\\\"1.0\\\\" encoding=\\\\"utf-8\\\\"?><Error><Code>RequestBodyTooLarge</Code><Message>The request body is too large and exceeds the maximum permissible limit._RequestId:373eedfa-c003-006f-2ee1-378ab6000000_Time:2024-11-16T04:41:02.5731809Z</Message><MaxLimit>131584</MaxLimit></Error>\\\\""}\'')}
Traceback (most recent call last):
File "/home/airflow/.local/lib/python3.8/site-packages/osdu_airflow/eds/eds_ingest/src_dags_fetch_and_ingest.py", line 80, in fetch_and_ingest
status = data_ingestor.load_data(
File "/home/airflow/.local/lib/python3.8/site-packages/osdu_airflow/eds/eds_ingest/data_ingestor/data_ingestor.py", line 11, in load_data
response = osdu_data_ingestor_obj.ingest_records(cleaned_records, criteria_dict)
File "/home/airflow/.local/lib/python3.8/site-packages/osdu_airflow/eds/eds_ingest/data_ingestor/implementation/osdu_data_ingestor.py", line 54, in ingest_records
raise Exception(
Exception: Failed to create records from the workflow. Received status: 500. Received content: b'{"code":500,"reason":"Unable to Enqueue workflow run","message":"Status code 413, \\"\xef\xbb\xbf<?xml version=\\"1.0\\" encoding=\\"utf-8\\"?><Error><Code>RequestBodyTooLarge</Code><Message>The request body is too large and exceeds the maximum permissible limit._RequestId:373eedfa-c003-006f-2ee1-378ab6000000_Time:2024-11-16T04:41:02.5731809Z</Message><MaxLimit>131584</MaxLimit></Error>\\""}'
CC : @AshishSaxenaAccenture , @ekay , @Atul, @priyankabhongade , @jeyakumar-jk