DEMO概述

连接器

所有DEMO元素中，模拟外部数据源，使用的都是同一个连接器元素，使用了OceanBase数据库（仅2025/12/31前有效，该日期之后会更改为其他数据库）

• 连接信息：

  • MySQL CLI：mysql -h obmt6cpicfamla2o-mi.aliyun-cn-hangzhou-internet.oceanbase.cloud -P 3306 -u demo -D demo -p

  • OBClient：obclient -h obmt6cpicfamla2o-mi.aliyun-cn-hangzhou-internet.oceanbase.cloud -P 3306 -u demo -p

• 账号：demo

• 密码：|G}EW8-x8+eGOc(p2QR

0101-同步开票数据&生成凭证

0101

0102-科目余额表集成&科目映射

DEMO地址：https://alpha.deepfos.com/element-deep-pipeline/3-0-0/?elementName=demo0102&folderId=DIRa796fd85b181&moduleId=DPL3_0&sign=YXBwSWQ9Y3pqbml3MDE5JnNwYWNlPWN6am5pdw%3D%3D

DEMO备注：202301到202512都有测试数据，每月7条数据，每次run会覆盖该月数据

DEMO元素：

此处为语雀卡片，点击链接查看

0201-上线迁移未结数据

0201

0301-销售&费用&分摊流程

0301

0401-预算分摊

DEMO使用说明：

1. 按【城市】模拟填写去年的实际数，省级数据自动汇总（可以修改已有数据）

   
   
   
   
   

2. 按【省】模拟填写今的预算数（可以修改已有数据），城市级数据等待数据流分摊计算

   
   
   
   
   

3. 启动数据流，输入年份和【省】的编码，会开始分摊对应年份、对应省份的今年预算

   
   
   
   
   

4. 等待数据流执行完成（1分钟左右），刷新电子表格，已完成分摊

   
   
   
   
   

0402-预算合并

DEMO使用说明：

1. 模拟门店业务人员，填写各门店、不同品类的预算，模拟审批状态=1（已审批），0（未审批）的不包含在计算范围内。（可以修改已有数据）

   
   
   
   
   

2. 区域级的预算还为空，等待数据流合并计算

   
   
   
   
   

3. 启动数据流，输入年份，开始聚合预算

   
   
   
   
   

4. 等待数据流执行完成（半分钟左右），刷新电子表格，已完成合并

   
   
   
   
   

0403-预算分摊

DEMO使用说明：

1. 维护全局变量的年月

   
   
   
   
   

2. 不区分成本中心，填写各部门的预算

   
   
   
   
   

3. 维护各部门，不同成本中心的占比

   
   
   
   
   

4. 启动数据流，指定版本，会开始分摊本期的预算

   
   
   
   
   

5. 等待数据流执行完成，刷新电子表格，已完成分摊

• 数据流页面点击【运行】是”集成模式“（更适高并发），会有启动开销，等待（约35秒）

• 通过UX、电子表格调用【同步】运行，是”非集成模式”(速度快，但不适合高并发)，不会有启动开销，同样场景运行（约3-5秒）

  
  
  
  
  

1. 使用deepcube的display_data()打印数据

   
   
   
   
   

0501-批量发布工作流

元素包（请将数据流组件升级到最新版本后再导入元素包，导入后两个数据流都需要发布，才可以运行，运行demo0501_Main这个主流程即可）：demo0501.zip

实现思路：

1. 先定义一个子流程，包含HTTP API节点，用于调工作流发布接口，这个接口只能发布单个工作流，本demo的需求是要发布app内所有工作流，所以后续需要有父流程来批量调用子流程

   1. HTTP API节点使用手册：HTTP API — 标准 | DeepFOS Docs

   2. 调接口的header需要用到space、app、cookie，这些信息都可以通过deepfos的OPTION获取，详见开始节点中配置的参数转换

2. 再来定义父流程，首先需要查询本app内的所有数据流元素，取得元素编码、路径，将这些元素作为要发布的目标对象

   1. demo中使用了DeepModel查询的方式来组成目标的工作流元素，前提是需要在DeepModel控制台，把【预置对象-元素对象】拖进画布，才会出现SystemElement对象，否则会抛出edgedb.errors.InvalidReferenceError: object type or alias '{appid}::SystemElement' does not exist的错误

   2. 当然，您可以根据自己的需要，自由组装出包含elementName``path``versionName三列的数据集，这将作为批量调用发布接口的传参

3. 再用数据流节点，批量调用第一步定义的子流程