windows下安装es及logstash、kibna

1、安装包下载
elasticsearch
https://www.elastic.co/cn/downloads/past-releases#elasticsearch


kibana安装包地址:
https://www.elastic.co/cn/downloads/past-releases/kibana-8-10-4

logstash安装包地址:
https://www.elastic.co/cn/downloads/past-releases/logstash-8-10-4


elasticsearch-analysis-ik包下载地址:
https://github.com/medcl/elasticsearch-analysis-ik/releases


2、解压安装包,并将elasticsearch-analysis-ik-8.10.4目录放到es的plugins目录下


3、修改es的config目录下的elasticsearch.yml


4、在终端启动es,在bin目录下点击elasticsearch.bat


5、在浏览器上查看

6、设置kibana的中文显示,修改kibana.yml


 

7、使用logstash进行mysql数据库数据同步到es配置

logstash.conf配置

# 连接到mysql数据库
input {
  jdbc {
    # MySQL JDBC驱动库的路径
    jdbc_driver_library => "D:\soft\third_soft\elasticsearch\logstash-8.10.4\config\mysql-connector-java-8.0.11.jar" 
    jdbc_driver_class => "com.mysql.cj.jdbc.Driver"
    # MySQL数据库的连接字符串
    jdbc_connection_string => "jdbc:mysql://127.0.0.1:3306/main_literature?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true"
    # MySQL数据库的用户名
    jdbc_user => "root"
    # MySQL数据库的密码
    jdbc_password => "****"
    # 开启分页
    jdbc_paging_enabled => true
    # 分页每页数量,可以自定义
    jdbc_page_size => "10000"
    # 查询语句
    statement => "SELECT * FROM literature_parsing_record WHERE id > :sql_last_value"
    # 定时执行的时间间隔,这里设置为每分钟执行一次。含义:分、时、天、月、年
    schedule => "* * * * *"
    # 定义的类型名称,说明哪个输入到哪个输出类型,与output中的if判断值对应
    type => "literature_parsing_record"
    # 是否开启记录上次追踪的结果,也就是上次更新的时间,这个会记录到last_run_metadata_path的文件
    use_column_value => true
    # 记录上一次追踪的结果值
    last_run_metadata_path => "D:\soft\third_soft\elasticsearch\logstash-8.10.4\config\track_id"
    # 用于增量同步的字段,如果use_column_value为true,配置本参数,追踪的column名,可以是自增id或时间
    tracking_column => "id"
    # tracking_colum 对应字段的类型
    tracking_column_type => numeric
    # 是否清除 last_run_metadata_path 的记录,true则每次都从头开始查询所有的数据库记录
    clean_run => false
    # 列字段是否都转为小写名称
    lowercase_column_names => false
    # 设置时区
    jdbc_default_timezone =>"Asia/Shanghai"
  }
  jdbc {
    # MySQL JDBC驱动库的路径
    jdbc_driver_library => "D:\soft\third_soft\elasticsearch\logstash-8.10.4\config\mysql-connector-java-8.0.11.jar" 
    jdbc_driver_class => "com.mysql.cj.jdbc.Driver"
    # MySQL数据库的连接字符串
    jdbc_connection_string => "jdbc:mysql://127.0.0.1:3306/main_literature?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true"
    # MySQL数据库的用户名
    jdbc_user => "root"
    # MySQL数据库的密码
    jdbc_password => "*****"
    # 开启分页
    jdbc_paging_enabled => true
    # 分页每页数量,可以自定义
    jdbc_page_size => "10000"
    # 查询语句
    statement => "SELECT * FROM literature_content_record WHERE id > :sql_last_value"
    # 定时执行的时间间隔,这里设置为每分钟执行一次。含义:分、时、天、月、年
    schedule => "* * * * *"
    # 定义的类型名称,说明哪个输入到哪个输出类型,与output中的if判断值对应
    type => "literature_content_record"
    # 是否开启记录上次追踪的结果,也就是上次更新的时间,这个会记录到last_run_metadata_path的文件
    use_column_value => true
    # 记录上一次追踪的结果值
    last_run_metadata_path => "D:\soft\third_soft\elasticsearch\logstash-8.10.4\config\literature_content_record_track_id"
    # 用于增量同步的字段,如果use_column_value为true,配置本参数,追踪的column名,可以是自增id或时间
    tracking_column => "id"
    # tracking_colum 对应字段的类型
    tracking_column_type => numeric
    # 是否清除 last_run_metadata_path 的记录,true则每次都从头开始查询所有的数据库记录
    clean_run => false
    # 列字段是否都转为小写名称
    lowercase_column_names => false
    # 设置时区
    jdbc_default_timezone =>"Asia/Shanghai"
  }
}

# 过滤数据
filter {
  mutate {
    # 移除Logstash自动生成的字段
    remove_field => ["@version", "@timestamp"] 
  }
}


# 连接到Elasticsearch
output {
  if[type]=="literature_parsing_record" {
    elasticsearch {
        # Elasticsearch的主机和端口
        hosts => ["http://localhost:9200"]  
        # 写入es的索引名称
        # index => "%{[@metadata][beat]}-%{[@metadata][version]}-%{+YYYY.MM.dd}"
        index => "literature_parsing_record"
        # es的文档类型名称,6.x版本可以是一个索引对应多个文档类型,不建议这么做。之后版本只支持一个索引对应一个文档类型
        document_type => "doc"
        # 使用数据中的id字段作为文档id
        document_id => "%{id}" 
        # 如果使用自己配置的模板,必须配置true
        # manage_template => true
        # 
        # template_overwrite => true
        # 模板名称,与定义的模板名称对应
        # template_name => "literature_parsing_record"
        # 使用自定义模板的文件路径,模板用于创建es的索引,决定了索引的创建方式
        # template => "/opt/elasticsearch/logstash-6.6.1/template/literature_parsing_record_logstash.json"
        #user => "elastic"
        #password => "changeme"
    }
  }
  if[type]=="literature_content_record" {
    elasticsearch {
        # Elasticsearch的主机和端口
        hosts => ["http://localhost:9200"]  
        # 写入es的索引名称
        # index => "%{[@metadata][beat]}-%{[@metadata][version]}-%{+YYYY.MM.dd}"
        index => "literature_content_record"
        # es的文档类型名称,6.x版本可以是一个索引对应多个文档类型,不建议这么做。之后版本只支持一个索引对应一个文档类型
        document_type => "doc"
        # 使用数据中的id字段作为文档id
        document_id => "%{id}" 
        # 如果使用自己配置的模板,必须配置true
        # manage_template => true
        # 
        # template_overwrite => true
        # 模板名称,与定义的模板名称对应
        # template_name => "literature_content_record"
        # 使用自定义模板的文件路径,模板用于创建es的索引,决定了索引的创建方式
        # template => "/opt/elasticsearch/logstash-6.6.1/template/literature_content_record_logstash.json"
        #user => "elastic"
        #password => "changeme"
    }
  }
  
  stdout {
      codec => json_lines
  }
}

8.下载mysql-connector-java-8.0.11.jar,放到配置的路径下

9、在终端启动logstash就可以进行数据同步了

logstash -f  D:\soft\third_soft\elasticsearch\logstash-8.10.4\config\logstash.conf

 10、在bin目录下启动kibana

11、点击开发工具查看

12、查看es中的数据

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/130766.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

18 Linux 阻塞和非阻塞 IO

一、阻塞和非阻塞 IO 1. 阻塞和非阻塞简介 这里的 IO 指 Input/Output(输入/输出),是应用程序对驱动设备的输入/输出操作。当应用程序对设备驱动进行操作的时候,如果不能获取到设备资源,那么阻塞式 IO 就会将对应应用…

CVE-2023-25194 Kafka JNDI 注入分析

Apache Kafka Clients Jndi Injection 漏洞描述 Apache Kafka 是一个分布式数据流处理平台,可以实时发布、订阅、存储和处理数据流。Kafka Connect 是一种用于在 kafka 和其他系统之间可扩展、可靠的流式传输数据的工具。攻击者可以利用基于 SASL JAAS 配置和 SASL …

文本生成高精准3D模型,北京智源AI研究院等出品—3D-GPT

北京智源AI研究院、牛津大学、澳大利亚国立大学联合发布了一项研究—3D-GPT,通过文本问答方式就能创建高精准3D模型。 据悉,3D-GPT使用了大语言模型的多任务推理能力,通过任务调度代理、概念化代理和建模代理三大模块,简化了3D建模的开发流程…

Linux 进程的管道通信

文章目录 无名管道pipe有名管道 进程之间的通信:Linux环境下,进程地址空间相互独立,每个进程各自有不同的用户地址空间。任何一个进程的全局变量在另外一个进程中都看不到,所以进程之间不能相互访问,要交换数据必须通过…

java学习part01

15-Java语言概述-单行注释和多行注释的使用_哔哩哔哩_bilibili 1.命令行 javac编译出class文件 然后java运行 2. java文件每个文件最多一个public类 3.java注释 单行注释 // 多行注释 文档注释 文档注释内容可以被JDK提供的工具javadoc所解析,生成一套以网页文…

赛氪ETTBL全国商务英语翻译大赛入榜国内翻译赛事发展评估报告

中国外文局下属CATTI项目管理中心出具2023 国内翻译赛事发展评估报告,ETTBL全国商务英语翻译大赛赫然在榜 2023年11月6日,继2022年首次发布国内翻译赛事发展评估报告后,中国外文局CATTI项目管理中心和中国外文界平台联合发布了《2023国内翻译…

JVM字符串常量池StringTable

目录 一、StringTable为什么要调整 二、String的基本特性 三、String的内存分配 四、字符串拼接操作 五、intern()方法 六、Stringtable的垃圾回收 七、G1中String去重操作 一、StringTable为什么要调整 jdk7之前,hotspot对于方法区的实现是永久代&#xff…

基于若依的ruoyi-nbcio流程管理系统仿钉钉流程json转bpmn的flowable的xml格式(排它条件网关)

更多ruoyi-nbcio功能请看演示系统 gitee源代码地址 前后端代码: https://gitee.com/nbacheng/ruoyi-nbcio 演示地址:RuoYi-Nbcio后台管理系统 这个章节来完成并行网关与排它条件网关的功能 1、前端 目前就修改了排它条件网关的前端条件部分&#xf…

嵌入式养成计划-52----ARM--开发板介绍--相关硬件基础内容介绍--GPIO讲解

一百三十一、开发板介绍 131.1 核心板介绍 131.2 拓展板 一百三十二、相关硬件基础内容介绍 132.1 PCB PCB( Printed Circuit Board),中文名称为印制电路板,又称印刷线路板, 是重要的电子部件,是电子元器…

springboot全局拦截sql异常

起因:非法用户可通过特定的输入(如输入内容超长)等操作,使后台逻辑发生错误,从而使后台sql语句暴露至前台,进而为sql攻击提供条件 处理流程:经查找com.mysql.cj.jdbc.exceptions的父类为SQLException,在全局异常处理类中增加如下配置,经测试不起作用 ExceptionHandler(SQLExce…

款网络拓扑自动扫描工具

Topology-Scanner是WeOps团队免费开放的一个网络拓扑自动扫描模块,可以自动发现网络设备的类型、网络设备之间的互联 使用方式 java -jar ./topology-scanner.jar --config_path./config/ 配置说明 1. 拓扑发现请求参数文件(request.json) ips [全网发现] 模式时…

asp.net core weapi 结合identity完成登录/注册/角色/权限分配

1.安装所需要的nuget包 <PackageReference Include"Microsoft.AspNetCore.Identity.EntityFrameworkCore" Version"6.0.24" /><PackageReference Include"Microsoft.EntityFrameworkCore" Version"6.0.24" /><PackageR…

Git应用(1)

一、Git Git(读音为/gɪt/。中文 饭桶 )是一个开源的分布式版本控制系统&#xff0c;可以有效、高速地处理从很小到非常大的项目版本管理。 了解更多可到GIT官网&#xff1a;Git - Downloads GIT一般工作流程如下&#xff1a; 1&#xff0e;从远程仓库中克隆 Git 资源作为本地…

线程安全问题解析

线程内存模型 线程在工作的时候&#xff0c;如果涉及到需要访问对象的某个成员变量&#xff0c;比如下面的这个类里的amount 属性&#xff1a; class Goods {private int amount;// balabala.....} 线程在运行期间&#xff0c;首先把这个属性从主内存里load进自己的工作内存&…

leetcode:160. 相交链表

一、题目 原题链接&#xff1a;160. 相交链表 - 力扣&#xff08;LeetCode&#xff09; 函数原型&#xff1a; struct ListNode *getIntersectionNode(struct ListNode *headA, struct ListNode *headB) 二、思路 判断两个链表是否相交&#xff0c;只要判断两个链表是否有相同的…

图数据库Neo4j详解

文章目录 第一章 图和Neo4j1.1 图数据库概念1.1.1 图论起源1.1.2 节点-关系及图1.1.3 图数据库1.1.4 图数据库分类1.1.4 图数据库应用场景1.1.5 与关系型数据库对比1.1.6 图数据库优势 1.2 Neo4j介绍1.2.1 Neo4j是什么1.2.2 Neo4j特点1.2.3 Neo4j的优势1.2.4 Neo4j的限制1.2.5 …

揭秘系列: Goroutine调度器

现在不要担心理解上面的图片&#xff0c;因为我们将从非常基础的知识开始。 Goroutines分布在线程中&#xff0c;由Goroutine调度器在幕后处理。根据我们之前的讨论&#xff0c;我们知道一些关于Goroutines的事情&#xff1a; •从原始执行速度来看&#xff0c;Goroutines不一定…

Unity中全局光照GI的总结

文章目录 前言一、在编写Shader时&#xff0c;有一些隐蔽的Bug不会直接报错&#xff0c;我们需要编译一下让它显示出来&#xff0c;方便修改我们选择我们的Shader&#xff0c;点击编译并且展示编译后的Shader后的内容&#xff0c;隐蔽的Bug就会暴露出来了。 二、我们大概回顾一…

智慧畜牧小程序开发流程

本文将详细介绍智慧畜牧小程序的开发流程&#xff0c;包括需求分析、设计、开发、测试和上线等环节。同时&#xff0c;将深入思考智慧畜牧小程序的发展趋势和未来挑战&#xff0c;为读者提供有深度的思考和逻辑性的分析。 一、需求分析 1.明确目标用户&#xff1a;首先…

Bond配置文件配置

1、选择2个自己需要的网口&#xff0c;查看有哪些网口 [roothostname ~]# ifconfig -a [roothostname ~]#systemctl disable NetworkManager 开机不启动图形化网络服务 2、编辑网口的配置文件 [roothostname ~]# cd /etc/sysconfig/network-scripts [roothostname n…