Skip to content
Snippets Groups Projects

fix #12830

Merged Damien DESPRES requested to merge development into redmine-13657-gestion-timeseries
2 files
+ 11
4
Compare changes
  • Side-by-side
  • Inline
Files
2
+ 10
3
@@ -24,7 +24,7 @@ def tag_doc( the_doc ):
@@ -24,7 +24,7 @@ def tag_doc( the_doc ):
# tag_dict[tag] = False
# tag_dict[tag] = False
# isOpen?
# isOpen?
if 'license' in the_doc['metadata-fr'].keys() and not any( [x in the_doc['metadata-fr']['license'] for x in ["Licence de réutilisation des données d'intérêt général","Accord de réutilisation de données en accès privé et exclusif"] ] ):
if 'license' in the_doc['metadata-fr'].keys() and not any( [x in the_doc['metadata-fr']['license'] for x in ["Licence Mobilités","Licence de réutilisation des données d'intérêt général","Accord de réutilisation de données en accès privé et exclusif"] ] ):
tag_dict['isOpenAccess'] = True
tag_dict['isOpenAccess'] = True
else:
else:
tag_dict['isOpenAccess'] = False
tag_dict['isOpenAccess'] = False
@@ -158,8 +158,15 @@ def index_docs(channel, method, properties, body):
@@ -158,8 +158,15 @@ def index_docs(channel, method, properties, body):
else:
else:
channel.basic_nack(delivery_tag = method.delivery_tag, requeue=1)
channel.basic_nack(delivery_tag = method.delivery_tag, requeue=1)
#print("")
#print("")
logging.error(es_body)
#logging.error(json.dumps(rep, indent=4))
logging.error(json.dumps(rep, indent=4))
try:
 
logging.error(json.dumps([
 
item.get("index", {}).get("error", {}).get("reason")
 
for item in rep.get("items", [])
 
],
 
indent=4))
 
except:
 
pass
raise Exception('Failed to push documents to Elasticsearch.')
raise Exception('Failed to push documents to Elasticsearch.')
return
return
Loading