From 347eb1022b46344e7303c1d4ebcd7dbfd516a498 Mon Sep 17 00:00:00 2001
From: Aparajitha <aparajitha88@gmail.com>
Date: Thu, 1 Oct 2020 17:24:25 +0530
Subject: [PATCH] Create elasticsearh_data.py

---
 elasticsearh_data.py | 42 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 42 insertions(+)
 create mode 100644 elasticsearh_data.py

diff --git a/elasticsearh_data.py b/elasticsearh_data.py
new file mode 100644
index 0000000..bf65b6c
--- /dev/null
+++ b/elasticsearh_data.py
@@ -0,0 +1,42 @@
+import requests
+import json
+import datetime
+import logging
+from threading import Thread
+from queue import Queue
+import glob
+import os
+import functools
+headers = {"Content-Type":"application/json"}
+path = r'C:\Users\Manikindi_shaik_Noor\Desktop\batool\esx-localhost-2020-07-16--10.31-2355077.tgz'
+
+
+elastic_url = "http://%s/%s/%s" % (
+    1.1.1.1:8080",
+    "new_index_blob",
+    "_doc/execution-b9aaa19c-c3b7-4925-94fc-bad39d0b1b91sosreport-MX5108N-A1-20200927083834.tar.xz"
+)
+import base64
+
+try:
+    with open(path, "rb") as f:
+        bytes = f.read()
+        encoded = str(base64.b64encode(bytes).decode("utf-8") )
+
+    upload_data = {}
+    upload_data["name"] = "esx-localhost-2020-07-16--10.31-2355077.tgz"
+    upload_data["blob"] = encoded
+except Exception as e:
+    print(str(e))
+
+try:
+    # print(upload_data)
+    resp_elastic = requests.put(
+        elastic_url,
+        headers=headers,
+        data=json.dumps(upload_data),
+        verify=False
+    )
+    print("ES Entry completed for {}".format(path))
+except Exception as e:
+    print(e)