Kafka 时间序列属性
概述
使用以下配置设置来指定MongoDB Kafka sink连接器应如何将数据沉入MongoDB时间序列集合。
有关按类别组织的数据沉连接器配置设置的列表,请参阅数据沉连接器配置属性指南.
设置
名称 | 描述 | |
---|---|---|
timeseries.timefield | 类型:字符串 描述 在源数据中包含要关联到时间序列集合中新文档的时间信息的顶级字段的名称。 默认值: "" 接受的值:空字符串或包含BSON DateTime 值的字段的名称 | |
timeseries.timefield.auto.convert.date.format | 类型:字符串 描述 连接器应使用该日期格式模式转换由 timeseries.timefield 设置指定的字段中的源数据。连接器将日期格式模式传递给JavaDateTimeFormatter.ofPattern(pattern, locale)方法用于对时间字段进行日期和时间转换。 如果源数据中的日期值只包含日期信息,连接器将时间信息设置为指定天的开始。如果日期值不包含时区偏移量,连接器将偏移量设置为UTC。 默认值:
可接受值:有效的 DateTimeFormatter 格式 | |
timeseries.timefield.auto.convert | 类型:布尔型 描述 是否将字段中的数据转换为BSON Date 格式。当设置为 true 时,连接器使用自纪元以来的毫秒数并丢弃小数部分(如果值是数字)。如果值是字符串,连接器使用以下配置中的设置来解析日期
如果连接器无法转换值,则将其发送到时间序列集合的原始值。 默认值: false 可接受值: true 或false | |
timeseries.timefield.auto.convert.locale.language.tag | 类型:字符串 描述 使用日期格式模式时要使用的 DateTimeFormatter 区域语言标签(例如:"en-US" )。有关区域设置的更多信息,请参阅Locale的Java SE文档。 默认值: ROOT 可接受值:有效的 Locale 语言标签格式 | |
timeseries.metafield | 类型:字符串 描述 从源数据中读取哪个顶层字段来描述一组相关的时间序列文档。 重要:此字段不能是 _id 字段,也不能是您在 timeseries.timefield 设置中指定的字段。默认值: "" 有效值:一个空字符串或包含任何 BSON 类型(除了 BsonArray )的字段名称。 | |
timeseries.expire.after.seconds | 类型: int 描述 MongoDB 在自动删除时间序列集合数据之前应等待的秒数。当设置值小于 1 时,连接器将禁用定时过期。要了解更多信息,请参阅 MongoDB 手册中的设置时间序列集合的自动删除。 默认值: 0 有效值:一个整数 | |
timeseries.granularity |
有关如何将现有集合转换为时间序列集合的示例,请参阅将现有集合迁移到时间序列集合的教程。