#!/usr/bin/python # -*- coding: latin-1 -*- import requests import json import sys from datetime import datetime # Parametros de entrada programa = str(sys.argv[1]) tipo = str(sys.argv[2]) mensagem = str(sys.argv[3]) #connectando ao cluster from elasticsearch import Elasticsearch es = Elasticsearch([{'host': 'localhost', 'port': 9200}]) #tentando acessar try: res = requests.get('http://localhost:9200') except Exception as ex: print("Error:", ex) #Inserindo dados no ElasticSearch def insert_elastic(programa, tipo, mensagem): doc = { 'author': 'DominaTudo', 'sistema': programa, 'tipo': tipo, 'message': mensagem , 'timestamp': datetime.utcnow(), } res = es.index(index="teste_auto", doc_type='teste', body=doc) print(res['result']) #Executa funcao que insere no ElasticSearch insert_elastic(programa, tipo,mensagem)
segunda-feira, 21 de outubro de 2019
Python - Inserindo no ElasticSearch
Assinar:
Postar comentários (Atom)
Nenhum comentário:
Postar um comentário