基于nats发布订阅消息框架,开发剑鱼数据流式处理流程

mxs 83b576d325 流式-数据保存 hai 1 ano
historyRepeat ff2417d4a3 初始化 hai 1 ano
reFile ff2417d4a3 初始化 hai 1 ano
savebidding 83b576d325 流式-数据保存 hai 1 ano
util 83b576d325 流式-数据保存 hai 1 ano
README.md 382175d071 更新 'README.md' hai 1 ano
conf.yaml ff2417d4a3 初始化 hai 1 ano
dataflow ff2417d4a3 初始化 hai 1 ano
go.mod 83b576d325 流式-数据保存 hai 1 ano
go.sum 83b576d325 流式-数据保存 hai 1 ano
main.go ff2417d4a3 初始化 hai 1 ano

README.md

dataflow

基于nats发布订阅消息框架,开发剑鱼数据流式处理流程;客户端通过配置文件编排数据处理流程,编排样例: process:

name: 招标数据流处理
subject: dataprocess
steps: [topclass, extract, save]
remark: 生产环境:招标分类class--》结构化抽取extract--》数据保持save