message处理流程
2022-09-26 13:58:36 0 举报test
作者其他创作
大纲/内容
LogPipe
合并文件topic
获取当前机器操作的文件名称
oss子文件
缓存补偿
sftp协议上传文件
SFTPInitPipe>>MergeFileDetailDTO
iop_file
GatewayFileHandler关于文件的，追加、合并、映射数据的初始化，缓存清理
iop_file_mapping
fileName>>count
GatewayFileInitPipe>>GatewayFileDTO
接收申报数据topic
ip_16>>fileName
清除线下机器的文件映射
获取调用sftp服务的配置信息
GatewayAppendFilePipe
GatewayFileMappingClearJobProcessor
fileName>>ossNextPosition
获取待处理文件
获取写入点
SFTPMergePipe
更新子文件状态
GatewayFileClearJobProcessor
更新文件行数
GatewayJobProcessor
GatewayLocalFileClearJobProcessor
iop_sftp_tag_mapping
SFTPUploadPipe
收藏
0 条评论
下一页
