描述
包含 S3Queue 元数据的内存状态,以及每个文件当前处理中的行。列
zookeeper_path(String) — ZooKeeper 中元数据的路径file_path(String) — 正在处理的文件的文件路径file_name(String) — 正在处理的文件的文件名rows_processed(UInt64) — 当前正在处理的行数status(String) — 处理状态:Processed、Processing、Failed,或 None (表示 cache 已知该文件但没有对应状态,例如处理已被 reset 的文件) 。若processing_observed_in_keeper_time非空,则表示Processing状态并非由持有该文件的处理器设置,而是从 Keeper 中读取到的processing_start_time(Nullable(DateTime)) — 文件开始处理的时间processing_end_time(Nullable(DateTime)) — 文件处理结束的时间exception(String) — 处理期间发生的异常。始终是本 server 最近一次尝试产生的异常,而非 Keeper 为该文件存储的异常processing_observed_in_keeper_time(Nullable(DateTime)) — 本 server 的某个处理器未能取得该文件、转而从 Keeper 读取Processing状态 (而非自行设置该状态) 的时间。通常该文件由另一台 server 持有,但也可能由本 server 中刚刚取得它的某个处理器持有。无论哪种情况,rows_processed、processing_start_time、processing_end_time和exception描述的都是本 server 最近一次处理该文件的尝试,而非当前持有该文件的处理过程