Skip to main content

专属算力

从 v5.1.0 版本开始，支持在组织中创建专属算力服务，将重要的工作流添加到专属算力服务中运行，可避免受平台其他流程堵塞影响。

专属算力服务仅支持在集群模式下部署，利用 kubernetes 污点特性，将专属算力服务 (workflowcompute) 运行在与微服务隔离的服务器中，从而避免受到其他服务资源占用的影响。

在部署专属算力服务后，服务器将根据页面上所选择的专属算力资源规格进行创建 workflowcompute 服务。这个服务在 kubernetes 上以 workflowcompute-资源ID 的格式命名，作为 deployment 资源显示。在每个 pod 中，会启动以下三个容器：

  • istio-proxy：这是 istio 的代理容器
  • worksheetservice：这是工作表服务容器，负责处理工作表相关的任务
  • workflow-consumer：这是工作流消费服务容器，负责处理工作流消费相关的任务

此外，kubernetes 的 limit 规则会对每个容器进行 cpu 和内存资源限制，限制值通常与页面上显示的专属算力资源规格相等。

同时，系统会根据所选并发数在 kafka 中创建一个新的 topic，该 topic 以 md-workflow-consumer-资源ID 格式命名，分区数默认与所选专属算力并发数相等。

在将特定的工作流加入到专用的算力服务后，对应流程将会走独立的 topic，使用专用的工作流消费服务和工作表服务进行处理，从而避免受到平台其他流程堵塞的影响。