zoukankan      html  css  js  c++  java
  • python 往 elasticsearch 存入数据,然后通过kinaba 检索分析

    es = Elasticsearch(hosts=[{'host': "elb-elasticsearch.cn-north-1.elb.amazonaws.com.cn", 'port': "9200"}],
    http_auth=("username", "password"))
    t = datetime.fromtimestamp(int(1529986664), pytz.timezone('Asia/Shanghai'))print(t)
    data = { 
    "region":"cn",
    "env":"dev",
    "product":"reliability",
    "service":"devops",
    "objectType":"ec2",
    "endpoint":"cn-dev-reliability-devops-ec2-172.31.116.5",
    "metric":"tcp_syn_sent",
    "value":800,
    "timestamp":t,
    "begintime":t, "starttime":0, "endtime":0, "step":60, "counterType":"COUNTER", "tag":"{aaa==1,bbb=2}", "dataSource":"transfer", "kinesis":"true" } es.index(index="kinesis-2015.06.26", doc_type="testdata", body=data)


    注释:
    "timestamp":t, 传入时间参数 不要对时间格式化,否则会报错,也许跟我用的elk时间戳配置有关,如果遇到类似问题可以注意下。


  • 相关阅读:
    mysql安装及初始密码问题
    centos7上安装erlang22.1
    共享文件夹设置
    putty免密登录
    重新开始
    单任务多线程 安全
    线程池
    多线程
    commons-IO
    打印流
  • 原文地址:https://www.cnblogs.com/husbandmen/p/9233390.html
Copyright © 2011-2022 走看看