检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
finished\n") }() } wg.Wait() fmt.Printf("send all complate ...") // 关闭发送实例 producerInstance.Close(60 * 1000) time.Sleep(10 * 60 * time.Second)
2:00:00, 12:10:00]区间内。 一次性任务如果处理某个文件失败后,扫描出来的其余文件不会再被解析上报到LTS。 固定间隔任务关闭后重新开启,监控数据连续性最多保持一天。 固定间隔任务在某个周期时间内处理文件失败后,该周期时间内扫描出来的其余文件不会再被解析上报到LTS。
me"。 log_transfer_status String 日志转储状态,ENABLE是指日志转储开启状态,DISABLE是指日志转储关闭状态,EXCEPTION是指日志转储异常状态 log_transfer_type String 日志转储类型。OBS指OBS日志转储,DI
RecordHeader("LTS_LOG_TYPE","FORMAT".getBytes())); producer.send(record); } // 3.关闭生产者 producer.close(); } } Python SDK调用示例。 from kafka import KafkaProducer
√ × √ 修改仪表盘 √ × √ 删除仪表盘 √ × √ 查询结构化配置 √ √ √ 配置结构化 √ × √ 开启快速分析 √ × √ 关闭快速分析 √ × √ 配置分词 √ × √ 查询过滤器 √ √ √ 禁用过滤器 √ × √ 启用过滤器 √ × √ 删除过滤器 √ × √
CSV文件中的nickname字段和字段值,与原始日志中的数据拼接,生成新的数据。 e_table_map(tab_parse_csv(res_obs_file("https://obs.xxx.myhuaweicloud.com","dsl-test-xx","data.csv")),"account","nickname")
String 错误码 最小长度:8 最大长度:36 error_msg String 错误描述 最小长度:2 最大长度:512 请求示例 GET https://{endpoint}/v1/{project_id}/lts/{member_account_id}/all-streams /
intercept(List<Event> list) 方法:事件批处理,拦截事件列表,并对事件列表进行处理。 close() 方法:关闭拦截器,在这里释放资源、关闭连接等。 import org.apache.flume.Event; import org.apache.flume.interceptor
error_code String 错误码。 error_msg String 调用失败响应信息描述。 请求示例 删除日志组 DELETE https://{endpoint}/v2/{project_id}/groups/{log_group_id} /v2/{project_id
修改结构化配置(推荐) 功能介绍 该接口通过结构化模板修改结构化配置 调用方法 请参见如何调用API。 URI PUT /v3/{project_id}/lts/struct/template 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
选true时,开启跨云后用户能通过公网(仅支持华北-北京四、华东-上海一、华南-广州、西南-贵阳一)访问(建议调测使用)。 选false时,关闭跨云后用户是通过华为云当前区域主机访问。 boolean 选填 false 如果是SpringBoot项目,则可以将logback.xml替换为logback-spring
me"。 log_transfer_status String 日志转储状态,ENABLE是指日志转储开启状态,DISABLE是指日志转储关闭状态,EXCEPTION是指日志转储异常状态 log_transfer_type String 日志转储类型。OBS指OBS日志转储,DI
请求示例 删除接入规则 DELETE /v2/{project_id}/lts/aom-mapping?id={id} DELETE https://{endpoint}/v2/{project_id}/lts/aom-mapping?id=3e14a212-a633-411d-a8e1-dc4042b1471a
error_code String 错误码。 error_msg String 调用失败响应信息描述。 请求示例 删除日志流 DELETE https://{endpoint}/v2/{project_id}/groups/{log_group_id}/streams/{log_stream_id}
e.printStackTrace(); System.out.println(e.getHttpStatusCode()); System.out.println(e.getRequestId());
error_msg String 错误描述 最小长度:1 最大长度:1000 请求示例 删除主机组,可同时删除多个主机组。 DELETE https://{endpoint}/v3/{project_id}/lts/host-group /v3/{project_id}/lts/host-group
error_code String 错误码。 error_msg String 调用失败响应信息描述。 请求示例 创建日志组 POST https://{endpoint}/v2/{project_id}/groups { "log_group_name" : "lts-group-01nh"
String 错误码。 最小长度:8 最大长度:8 error_msg String 调用失败响应信息描述。 请求示例 查询日志直方图 POST https://{endpoint}/v2/{project_id}/lts/keyword-count { "group_id" : "0
error_code String 错误码。 error_msg String 调用失败响应信息描述。 请求示例 修改日志流 PUT https://{endpoint}/v2/{project_id}/groups/{log_group_id}/streams-ttl/{log_stream_id}
查询结构化配置 功能介绍 该接口用于查询指定日志流下的结构化配置内容。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/lts/struct/template 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String