下载logstash镜像，这里使用6.2.2版本docker pull docker.elastic.co/logstash/logstash-oss:6.2.2本地运新这个镜像，docker run -d docker.elastic.co/logstash/logstash-oss:6.2.2查看logstash运行情况docker psCONTAINER IDIMAGECOMMAND

文章目录介绍安装使用clienthttpQA介绍pushgateway是Prometheus下的一个组件，用来当做采集对象和Prometheus的代理，Prometheus会定时的从gateway上面pull数据。由于服务部署在容器中，服务的ip会经常的变化，导致Prometheus无法直接拉取到每个target的数据。问题：多个服务的数据，推送到pushgateway，如果push挂了...

1.根据条件删除当前消息if "caoke" not in [docker]{drop {}}if "caoke" != [className]{drop {}}删除字段remove_field => ["message"]添加字段mutate{add_field => {"timestamp" => "%{[message]}"　　}}转换字段类型mutate{

文章目录Linux 查看磁盘空间可以使用 df 和 du 命令dfdudu -shdu log2012.logdu -h home实例Linux 查看磁盘空间可以使用 df 和 du 命令dfdf 以磁盘分区为单位查看文件系统，可以获取硬盘被占用了多少空间，目前还剩下多少空间等信息。例如，我们使用df -h命令来查看磁盘信息， -h 选项为根据大小适当显示：显示内容参数说明：File...

文章目录创建registry在 K8S 中使用私有镜像（我还没有完成）创建registry1.拉取registry镜像:docker pull registry:2.7[root@ ~]# docker pull registry:2.72.7: Pulling from library/registry486039affc0a: Pull completeba51a3b098e6: Pull c

文章目录配置规则Nginxfilebeatkafkalogstash附录logstash 相关功能urldecodelogstash 写入输出kafka范例vim快捷键参考文章需求背景：有一个对用户行为的分析需求，类似于用户在浏览某网页的时候，上报用户的行为信息。请求某个域名，参数信息带在url上面。类似于：http://www.baidu.com?content={"a:"b"}&us.

最近在做 logstash 消费 kafka 写到 es 的项目中，在 kibana 中查看发现 logstash 写入的 @timastamp 比真实服务器的时间少了8个小时。并且生成的文件中，日志切分的格式也是差了8小时。例如：2019-01-01的日志里面会写入2019-01-02 08:00:00 前的日志。因为logstash默认使用的是UTC时间。使用版本：namever...

ES JAVA API请求地址：线上:集群名称: data_cluster集群地址: es.data…comtcp端口：9300http端口: 80POM文件配置<dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId>&lt