服务解绑bls日志集 功能介绍 本接口用于预置服务和定制服务解绑bls日志集。 使用说明 本文API支持通过Python SDK、Go SDK、Java SDK 和 Node.js SDK调用,调用流程请参考 SDK安装及使用流程 。
7.2.7 2024-08-16 新增功能 支持审计日志,说明文档 去掉版本号中的 (Baidu Release) 字段。 7.2.6 2024-05-20 Bug修复 修复开启异步 AOF 写入时,关闭 AOF 时采用了同步关闭的问题。
响应参数 无 示例 请求示例 PUT /v1/logshipper/2333-0333/status HTTP/1.1 Host: bls-log.bj.baidubce.com Authorization: bce-auth-v1/18717522d39411e9b721df098b0b908c/2019-09-10T07:00:20Z/1800/content-type;host;x-bce-date
响应参数 参数名称 类型 是否可以为空 描述 status string no 运行状态, 可为运行中(Running)、异常(Abnormal)、已暂停(Paused) logShipperName string no 投递任务名称 project string no 日志组名称 logStoreName string no 日志集名称 startTime string no 指定投递开始时间 destType
响应参数 无 示例 请求示例 PUT /v1/logshipper/status/batch HTTP/1.1 Host: bls-log.bj.baidubce.com Authorization: bce-auth-v1/18717522d39411e9b721df098b0b908c/2019-09-10T07:00:20Z/1800/content-type;host;x-bce-date;
已传输数据:当前任务已传输的日志数据总量。 异常信息:如收集器在执行传输任务时出现异常,在这里查看异常报错信息,用于排查任务问题。 添加收集器、删除收集器:增加新的收集器或移除已有收集器。移除收集器后,该收集器的历史信息将不被保留,当重新部署同一传输任务到该收集器上时,已传输数据将从零开始重新计算。 下载:下载当前任务所有收集器的信息,便于离线查看和管理。
接收日志 日志接收提供rx风格的订阅接口,使用示例如下: logger.receive().subscribeWith(new DisposableObserver<LogEntry>() { @Override public void onNext(@NonNull LogEntry logEntry) { // handle logEntry System.out.println(logEntry
CreateIndex 描述 为用户指定的日志集创建索引。
订阅Kafka日志 用户可以通过提交例行导入作业,直接订阅Kafka中的消息数据,以近实时的方式进行数据同步。 PALO 自身能够保证不丢不重的订阅 Kafka 中的消息,即 Exactly-Once 消费语义。 准备工作 请提前构建Kafka服务,可以选择开通 百度消息服务 或自建Kafka服务。请确保 Kafka 服务和 Doris 集群在同一个 VPC 内,并且相互之间的网络能够互通。