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

2 Ramuri

0 Variante

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

dataflow

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

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