日志服务数据加工：原理篇
概述
日志服务加工服务的一个作业使用协同消费组, 对源日志库进行流式消费, 对每一条日志传给加工规则处理后再输出.
调度原理
调度机制
对每一个加工作业, 加工服务的调度器会启动一个或多个运行实例, 每个运行实例扮演一个消费者的角色去消费1个或者多个源logstore的shard, 调度器会根据运行实例的内存与CPU消耗情况决定或减少并行运行实例数, 最多启动与源logstore的shard数量一样的运行实例.
运行实例
对分配的每个shard读取用户配置的起点的数据, 在内存中将源日志传递给加载的加工规则引擎, 处理后, 再输出给配置的目标Logstore. 加工规则引擎也会根据规则从外部加载资源进行富化等操作. 运行实例会利用消费组机制保存每个shard消费到的位置, 确保意外停止后再启动时可以继续从断点处继续消费.
作业停止
当用户配置作业
关注公众号 低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有，本站原创内容转载请注明来源。
- 上一篇
Java之集合(一)
Java最初版本只为最常用的数据结构提供了很少的一组类Vector、Stack、HashTable、BitSet和Enumeration接口,其中Enumeration接口提供了一种用于访问任意容器中各个元素的抽象机制. 集合框架的基本设计:将接口(interfaces)与实现(implementations)分离.数据结构一队列队列是指可以在队列的尾部添加元素,在队列的头部删除元素,并且可以 查找队列中元素的个数,按照先进先出的规则检索对象.队列有两种实现方式,一种是循环组数,一种是链表.循环组数比链表更高效,但循环组数是一个有界集合,即容量有限,如果程序中要收集的对象数量没有上限,最好用链表来实现. Collection接口: 集合类的基本接口是Collection接口,是集合层次中的根接口.下面先看下Collection接口中的方法: int size(); 返回当前集合的元素个数 boolean isEmpty(); 判断集合是否为空,为空返回true boolean contains(Object o); 如果此集合包含指定的元素，则返回true Iterator itera...
- 下一篇
正确看待递归函数
什么是递归函数 我们都知道基本上的编程语言都支持在一个函数中调用其他的函数。如果这个函数在内部调用它自己，那么我们就称这个函数为递归函数。 递归函数的作用 可以执行for或while语句相同的任务 有些情况可以少写代码，让代码看起来更简练举一个例子，数学中我们有学习过求一个正整数的阶乘。阶乘是基斯顿·卡曼（Christian Kramp，1760～1826）于 1808 年发明的运算符号，是数学术语。一个正整数的阶乘（factorial）是所有小于及等于该数的正整数的积。我们使用PHP语言用两种方法实现阶乘的运算，代码如下： <?php //使用递归的方式 function factorial_1($n){ return $n == 1 ? 1 : $n * factorial($n - 1); } //使用while的方式 function factorial_2($n){ $res = 1; while ($n > 1) { $res = $res * $n--; } return $res; } $n = 5; echo "使用阶乘的方式：" . factoria...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- Linux系统CentOS6、CentOS7手动修改IP地址
- SpringBoot2整合Thymeleaf，官方推荐html解决方案
- CentOS6,7,8上安装Nginx，支持https2.0的开启
- CentOS6,CentOS7官方镜像安装Oracle11G
- 设置Eclipse缩进为4个空格，增强代码规范
- CentOS7,8上快速安装Gitea，搭建Git服务器
- CentOS7编译安装Cmake3.16.3，解决mysql等软件编译问题
- CentOS7,CentOS8安装Elasticsearch6.8.6
- SpringBoot2整合MyBatis，连接MySql数据库做增删改查操作
微信收款码
支付宝收款码