Abfragen von ElasticSearch mit Python-Anfragen

Question

, ich bin nicht ganz in der Lage, die Ergebnisse abzurufen, wenn ich versuche, ElasticSearch mit Python-Anfragen abzufragen. Hier ist mein Code:

json_data = updateJson(sys.argv[1]) 

headers={'Accept': 'application/json', 'Content-type': 'application/json'} 

elastic_url ='https://localhost:9200/logstash-kafka-wga-blueid-\*/_search' 

query = json.dumps(json_data) 

response = requests.get(elastic_url, data = query, auth=('xxx','xxx'), verify=False, headers = headers) 

print response.text 

Ich bekomme immer die folgende Ausgabe:

{"took":1,"timed_out":false,"_shards":{"total":0,"successful":0,"failed":0},"hits":{"total":0,"max_score":0.0,"hits":[]}} 

Aber wenn ich versuche, den folgenden ROTATION-Befehl zu verwenden, erhalte ich die richtigen Ergebnisse. Im obigen Code liest json_data den JSON aus der abc.json-Datei. Ist im obigen Code etwas falsch?

curl -X GET -k -u xxx:xxx https://localhost:9200/logstash-kafka-wga-blueid-\*/_search -d @temporaryRundeckReport.json 

Hier ist meine updateJson() Methode:

def updateJson(fileName): 
with open(fileName, 'r') as file: 
    json_data = file.read() 
    json_data = json_data.replace('%X-FORWARDED-HOST%', sys.argv[2]); 
    json_data = json_data.replace('%TIME%', sys.argv[3]); 
    json_data = json_data.replace('%INTERVAL%', sys.argv[4]); 

with open('temporaryRundeckReport.json', 'w+') as file: 
    os.chmod('temporaryRundeckReport.json',0o777) 
    file.write(json_data) 
    return json_data 

Answer 1

Ich glaube, Sie brauchen nicht zu Stern zu entkommen * in Python-Version (entfernen Schrägstrich): auch

elastic_url = 'https://localhost:9200/logstash-kafka-wga-blueid-*/_search' 

Aber , Würde ich empfehlen, die python client library anstelle von requests zu verwenden.