solve clash with "version" tag

Universite-Gustave-Eiffel · Jun 25, 2024 · cbf5f09 · cbf5f09
1 parent 4684e68
commit cbf5f09
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/services/ansible_openvpn/playbooks/files/scripts_elasticsearch/feed_rpi_data.py b/services/ansible_openvpn/playbooks/files/scripts_elasticsearch/feed_rpi_data.py
@@ -65,6 +65,9 @@ def fetch_data(args):
                             try:
                                 json_dict = json.loads(line)
                                 if "_index" not in json_dict:
+                                    if "_source" not in json_dict:
+                                        source_doc = json_dict
+                                        json_dict = {"_source": source_doc}
                                     # must create index as it is not specified in the
                                     # document
                                     epoch = os.path.getmtime(file_path)