pipeline

0热度

1回答

我在写一个后端服务，它向公共API端点发出API请求。来自API的响应以JSON形式发送。我正在使用request.js进行API调用，并且正在将实例request.Request返回给任何代码（在本例中为Express.js中的一个路由处理程序）。路由处理程序简单地将来自API回调的响应“管道化”回到请求路由的客户端。我有一个关于上述情况如下担忧：什么是实现一个实现了流接口，这样的业务逻辑的

1热度

1回答

如何在使用渠道的golang流水线阶段批量处理项目？

我读管道在线教程，并试图构建经营这样一个阶段 - 将它们发送到了陈如果我们还没有前批了传入事件中的10个批次的每个在5秒内没有看到10个事件，将我们收到的数量合并并发送给他们，关闭出局并返回。但是，我不知道第一个选择案例会是什么样子。尝试了很多事情，但无法通过这个。任何指针非常感谢！ func BatchEvents(inChan <- chan *Event) <- chan *Even

0热度

1回答

python中是否有任何工作流程工具或库？

我想创建3个进程（a，b，c）并将它们组合到一个工作流中。 ex: a---->b b---->c c---->end 输出a将发送给b的输入。我尝试了ruffus，但它设计用于文件转换。 Python中是否有工作流程库？

0热度

1回答

仅当用户在代码仓库中创建标签时触发代码管道

当用户在代码提交仓库中创建标签时，是否可以配置用于调用代码管道的云监视事件模式？或者有什么办法可以限制用户在每次提交时都不运行管道？

0热度

1回答

Swift Siesta重定向对失败的响应

是否可以使用Siesta管道，接收成功响应，解析它，并根据返回，将其重定向到失败响应？我的服务器响应多次返回一个HTTP 200，但带有错误消息/标志。

0热度

1回答

Confluent Rest Proxy API（生产者）重试事件发生失败

我们计划使用Confluent Rest代理作为侦听所有用户事件（&将它们发布到Kafka）的平台层。处理具有不同类型事件生成器的微服务模型&，我们希望我们的API /事件生成器与事件监听/处理分离。此外，在事件监听层，事件韧性对我们很重要。据我所知，如果Rest代理层出于任何原因无法发布到Kafka（曾经），它不会重试。该功能需要由调用者（客户层）处理，该调用者需要在发生故障时进行同步调用&重

0热度

1回答

为什么到命令组的管道只能用于某些命令？

我有兴趣在grep输出中保留输入的标题，就像在Include header in the 'grep' result这个问题中一样。虽然工作解决方案（使用sed）在问题中出现，但answer with most upvotes引起了我的注意。例如，它允许使用grep --color。这表明管道输入到command group与命令head和grep，如： ps -ef | { head -1;

0热度

1回答

文本处理流水线文件

我需要不明组源代码文件，然后执行以下操作：如果我发现某个类型（基本的声明，如果我找到一个基于正则表达式或简单搜索模式的关键字行）我需要在该行之前添加某些预定义的固定行。我需要将文件我需要基于正则表达式搜索执行一些线路的清理或设置基于一些标准线，为简单起见，在添加高于一切的标准注释。我到Windows机器上运行这一点，因为源代码将.NET和Java，因此我需要一个可以在Windows上安装的

0热度

3回答

如何在第一次匹配时停止管道过滤（Where-Object）

我搜索了，但没有找到如何去做。我正在从大文件（〜2GB）过滤数据。我使用Where-Object，当它找到匹配时，它继续搜索它有意义的其他匹配。是否有可能在第一场比赛中阻止它？例如（＃1）： Get-Process | Where-Object {$_.ProcessName.StartsWith("svchost")} 输出将是： Handles NPM(K) PM(K) WS(K

1热度

1回答

通知GitLab中失败管道的所有组成员

目标是让每个人都获得每个失败管道的通知（由他们自行决定）。目前，我们中的任何人都可以在此项目分支上运行管道，并且管道的创建者可以收到电子邮件，而其他人则不会。我试图在项目，组和全球级别上将通知级别设置为watch和custom (with failed pipelines checked)，但未成功。关于notifications的帮助页面显示，自定义通知级别的失败管道复选框通知管道作者（这是我正