使用Argo工作流创建队列系统

问题描述

我试图弄清楚如何使用 Argo 设置工作队列。 Argo工作流的计算量很大。我们需要计划许多同时请求。通过HTTP请求将工作流程项添加到工作队列。

流程可以像这样演示:

client  
  => hasura # user authentication  
    => redis # work queue
      => argo events # queue listener
        => argo workflows 
          => redis + hasura # inform that workflow has finished
            => client 

我从来没有建立超过其资源的K8s集群。我在哪里限制工作流程的执行?还是Argo事件和工作流根据集群中的资源限制了它们?

上面的示例可能会简化为以下示例,但是问题是如果processing queue is full会发生什么?

client
  => argo events # HTTP request listener
    => argo workflows

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)