datai/datai-scenes/datai-scene-salesforce/docs/api-docs/integration/RealtimeServiceController/0011-start-service.md
Kris ccc7109c31 feat(salesforce-integration): 完善实时同步和统计功能
主要变更:
- 新增实时同步日志统计接口,支持多维度统计(综合、对象、操作类型、状态、时间趋势)
- 新增实时同步统计接口,提供服务状态、对象统计和订阅统计
- 实现实时服务手动启动管理,移除自动启动注解
- 移除所有统计相关功能(EventProcessor、DataSynchronizer统计方法)
- 解决DataiIntegrationObjectServiceImpl和ObjectRegistryImpl循环依赖问题
- 完善元数据变更统计功能,支持自动时间范围和缺失数据点填充
- 修复SQL布尔值兼容性问题(true/false改为1/0)
- 新增SysJobController和SysJobLogController接口文档
- 更新项目文档和变更日志

技术细节:
- 添加@Lazy注解解决循环依赖
- 实现时间趋势统计的自动时间范围处理
- 支持多种时间单位(天、周、月、季度)的趋势分析
- 优化同步成功率计算和数据处理完整性
- 遵循项目文档规范,更新唯一真源
2026-01-13 13:51:33 +08:00

2.9 KiB
Raw Blame History

启动实时同步服务

接口概述

启动 Salesforce 实时同步服务,开始处理从 Salesforce 接收到的实时变更事件,并将数据同步到本地系统。

接口详情

  • 接口名称: 启动实时同步服务
  • 接口路径: /integration/realtime/service/start/service
  • 请求方法: POST
  • 权限标识: integration:realtime:start:service
  • 接口标签: 【实时服务管理】统一管理

请求参数

Headers

参数名 类型 必填 描述
Authorization String 认证令牌格式Bearer {token}
Content-Type String 请求内容类型固定值application/json

Query Parameters

Body Parameters

响应参数

响应结构

{
  "success": boolean,
  "message": String,
  "started": boolean
}

字段说明

字段名 类型 描述
success Boolean 请求是否成功true-成功false-失败
message String 响应消息,描述操作结果
started Boolean 服务状态true-已启动false-未启动

响应示例

成功响应

{
  "success": true,
  "message": "实时同步服务启动成功",
  "started": true
}

失败响应

{
  "success": false,
  "message": "实时同步服务启动失败: 初始化失败",
  "started": false
}

错误码说明

错误码 描述 解决方案
401 未授权token 无效或已过期 重新登录获取有效 token
403 无权限访问该接口 联系管理员分配相应权限
409 实时同步服务已在运行 无需重复启动,或先停止再启动
500 服务器内部错误 检查服务器日志,联系技术支持

注意事项

  1. 启动前请确保以下组件已就绪:
    • 对象注册表已初始化
    • 事件订阅服务已启动
    • 数据同步器已正确配置
  2. 启动前请确保数据库连接正常,有足够的存储空间
  3. 如果实时同步服务已在运行,再次调用此接口不会产生副作用
  4. 启动成功后,服务将开始处理以下任务:
    • 接收来自事件订阅器的变更事件
    • 解析事件数据
    • 调用数据同步器执行数据同步
    • 记录处理统计信息
  5. 建议在以下场景启动实时同步服务:
    • 系统初始化完成后
    • 事件订阅服务启动后
    • 实时同步服务停止后需要重新启动时
    • 配置更新后需要重新加载时
  6. 启动操作是幂等的,可以安全地重复执行
  7. 启动过程中会自动初始化事件处理器和数据同步器

相关接口