[datasync] from.odbserver=127.0.0.1:11001 from.keyspace=matrix to.odbserver=127.0.0.1:11001 to.keyspace=oktest # 可以配置多个 类名 或 查询语句,查询结果中必须包含 class id 字段 # 查询语句中可以指定 where 条件,不支持聚合、排序、limit 等子句 # 不配置将读取所有类数据 from.data=/test/ # from.data=/test/bucketpromdb from.data=select * from /test/alert_status where vtime>'2022-03-10 16:53:43' from.data=/matrix/ldap from.data=/matrix/group from.data=/matrix/perms/ # 不同步的类 deny.class=/matrix/jobs/ deny.class=/matrix/filesystem deny.class=/matrix/portal/ deny.class=/matrix deny.class=/m3event/ deny.class=/m3entity/ deny.class=/testdata1 deny.class=/testclasscache deny.class=/test_odbinsert deny.class=/testtagdir deny.class=/testdc1/ deny.class=/testdc2/ deny.class=/testruledata deny.class=/aywl/ # 只同步指定的最近一段时间的对象数据,默认 365d data.time.since=3000d # 只同步指定的最近一段时间的Bucket数据,默认 30d bucket.time.since=30d # 指定建类语句等初始化mql语句,可以是mql文件或mql语句,默认根据原始元数据信息自动建类 #to.init.mql= # 类映射 # mapping.class.fromclass=toclass # overwrite / ignore / error # exists=overwrite # 每秒写入数据量,同步上限 # limit.rate=50 # 对象数据同步并发数,默认cpu数 concur.threads=2 # Bucket数据同步并发数,默认cpu数 bucket.threads=2 # 每次读取数据的最大数量,默认50,立即生效 pagesize=10 # 每次读取数据的时间分段,默认一天,立即生效 pagetime=1d # 每次读取bucket数据的时间分段,默认1h,立即生效 bucket.pagetime=1d # 用于存放同步进度记录 data.dir=data # 持续运行间隔,数据同步到当前时间后,间隔指定时间轮询执行 # 默认 0 运行一次,数据同步到当前时间后退出 # 立即生效 run.interval=5s # 每次轮询读取数据的重叠时间,默认30s,立即生效 run.overtime=30s