-
Notifications
You must be signed in to change notification settings - Fork 1
/
elastics.py
67 lines (38 loc) · 1002 Bytes
/
elastics.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
from elasticsearch import Elasticsearch, helpers
import requests, sys, json, os
from pprint import pprint
from elasticsearch import Elasticsearch
import ast
es = Elasticsearch(
['localhost'],
port=9200
)
#default elastic #search PORT is #9200
res = requests.get('https://localhost:9200')
FILE = open("file.json",'r').read()
'''
ClearData = FILE.splitlines(True)
i = 0
json_str = ""
docs = {}
for line in ClearData:
line = ' '.join(line.split())
for word in line:
if word != "}":
json_str += word
else:
docs[i] = json_str + "}"
json_str = ""
es.index('tweets', doc_type='tweet', id = i, body = docs[i])
i+=1
res = es.get(index='tweets', doc_type='tweet', id=0)
print (res['_source'])
'''
def jsonToDicts(STR):
STRI = list(STR)
for i in range(0,len(STRI)):
if STRI[i] == "\"":
STRI[i] = "\'"
STRIN = ''.join(STRI)
STRING = ast.literal_eval(STRIN)
return STRING