From a51d29e48e6e7b5fb6e20dd88aec01e73eb98467 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=A9bastien=20DA=20ROCHA?= <sdarocha@neogeo.fr>
Date: Tue, 1 Mar 2022 11:35:19 +0000
Subject: [PATCH] Add error logs when indexing to ingest
---
workers/doc_indexer.py | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/workers/doc_indexer.py b/workers/doc_indexer.py
index cdc13be..efd34d2 100644
--- a/workers/doc_indexer.py
+++ b/workers/doc_indexer.py
@@ -159,6 +159,14 @@ def index_docs(channel, method, properties, body):
channel.basic_nack(delivery_tag = method.delivery_tag, requeue=1)
#print("")
#logging.error(json.dumps(rep, indent=4))
+ try:
+ logging.error(json.dumps([
+ item.get("error", {}).get("reason")
+ for item in rep.get("items", [])
+ ],
+ indent=4))
+ except:
+ pass
raise Exception('Failed to push documents to Elasticsearch.')
return
--
GitLab