随着 Kafka 社区的繁荣,越来越多的用户开始使用 Kafka 来进行日志收集、大数据分析、流式数据处理等操作。而腾讯云消息队列 Ckafka 也借助了开源社区的力量,进行了如下优化:
腾讯云云函数与 Ckafka 也进行了深度联动,并推出了很多实用的功能。借助云函数和 Ckafka 触发器,可以非常方便实现 CKafka 消息转存到 COS、ES、DB 等,本文介绍使用云函数替代 Logstash,实现 Ckafka 消息罗盘 ES。如下图所示:
云函数可以实时消费 Ckafka 中的消息。例如,做数据转存、日志清洗、实时消费等。且数据转存的功能已集成到 Ckafka 控制台,用户可以一键开启使用,降低了用户使用的复杂度。如下图所示:
对比使用云服务器自建 Ckafka Consumer 的方式,云函数具备以下优势:
使用云函数和使用云服务器 CVM 自建 Logstash 对比,云函数具备以下优势:
本文以广州地域为例:
key | value | 是否必填 |
---|---|---|
ES_Address | ES 服务地址 | 是 |
ES_User | ES 用户名,默认为 elastic。 | 是 |
ES_Password | ES 用户登录密码。 | 是 |
ES_Index_KeyWord | ES 关键词索引。 | 是 |
ES_Log_IgnoreWord | 需要删除的关键词,缺省则全量写入。例如,填写 name 或 password。 | 否 |
ES_Index_TimeFormat | 按照天或者小时设置 Index,缺省则按照天建立索引。例如填写 hour。 | 否 |
注意:如果您还未将实际数据接入消息队列 Ckafka,您可以通过 客户端工具 模拟消息生产。
若您需实现高级日志清洗逻辑,可在如下图所示的代码位置中修改逻辑:
操作场景 业务接入DDoS高防后,您可以通过查看高防实例线路的DDoS攻击防护日志和...
包年包月企业版实例 注意事项 包年包月购买的实例支持提前销毁退还,将按照实际...
操作场景 使用SDK、API或obsutil工具前,需要先获取OBS的终端节点(Endpoint)信...
随着前端项目不断扩大,浏览器渲染的压力变得越来越重。配置好一点的计算机可以...
想了解更多内容,请访问: 51CTO和华为官方战略合作共建的鸿蒙技术社区 https://...
操作场景 该任务指导客户进行如下操作: 关闭高防IP的域名解析功能。 新增域名的...
如今,「即服务 」的时代已经到来,将能力服务化,万物皆可具备基础设施的特征。...
本文介绍使用函数计算的流程,包括创建服务、创建函数、触发函数、查看执行日志...
随着业务规模的扩张,企业系统变得越来越复杂,在这种复杂的分布式系统架构下,...
服务器租用选择组装机还是品牌机 作为网站站长来讲,选择一款合适的服务器是至关...