elasticsearch和logstash 同步数据库和elasticsearch head安装

2020-06-17 17:29:00
admin
原创
96
摘要:elasticsearch和logstash 同步数据库和elasticsearch head安装

1、首先下载elasticsearch,我用的是6.3的版本

修改一下配置elasticsearch.yml

cluster.name: my-application

node.name: node-1

logstash 下载的也是6.3的

同步数据库,配置文件如下,新建一个mysql.cof放到conf目录下面

数据库的连接的jar包放到自己新建的mysql 目录下面,

配置文件的内容如下:


input {
  # 多张表的同步只需要设置多个jdbc的模块就行了
  jdbc {
      # mysql 数据库链接,shop为数据库名
      jdbc_connection_string => "jdbc:mysql://localhost:3306/aumalls?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC"
      # 用户名和密码
      jdbc_user => "root"
      jdbc_password => "123456"
      # 驱动
      jdbc_driver_library => "D:/soft/logstash-6.4.3/mysql/mysql-connector-java-8.0.16.jar"
      # 驱动类名
      jdbc_driver_class => "com.mysql.jdbc.Driver"
      #是否分页
      jdbc_paging_enabled => "true"
      jdbc_page_size => "50000"
      #直接执行sql语句
      statement =>"select * from au_goods"
      # 执行的sql 文件路径+名称
      # statement_filepath => "/hw/elasticsearch/logstash-6.2.4/bin/test.sql"
      #设置监听间隔  各字段含义(由左至右)分、时、天、月、年,全部为*默认含义为每分钟都更新
      schedule => "* * * * *"
      # 索引类型
      #type => "jdbc"
    }

}
output {
  elasticsearch {
        #es的ip和端口
        hosts => ["http://localhost:9200"]
        #ES索引名称(自己定义的,这个不用新建,同步的时候会自动新建)
            index => "blog"
        #文档类型
        document_type => "log"
        #设置数据的id为数据库中的字段
        document_id => "%{id}"
    }
    stdout {
        codec => json_lines
    }

}
不用新建索引,会自动新建索引


进入到logstash目录下面:执行之后,数据库的数据会同步到索引库中

bin\logstash.bat -f config\test.conf

2、elasticsearch head的安装

https://chrome.google.com/webstore/search/elasticsearch?h1=zh

科学上网,能访问到谷歌的应用商店,找到应用商店中的elasticsearch head进行安装


安装之后,直接用谷歌浏览器上面打开


运行效果如下:


    发表评论
    评论通过审核之后才会显示。
    文章分类
    联系方式
    联系人: 郑州-小万
    电话: 13803993919
    Email: 1027060531@qq.com
    QQ: 1027060531
    网址: www.wanhejia.com