Cadence或Temporal中的自定义工作流
我计划将 Cadence 或临时工作流用于架构，但我们计划在决定工作流时为用户提供很大的权力。在他们的用例中，节奏和时间都提到他们的SDK支持自定义DSL，但我看不到该功能。你能帮帮我吗？
共有1个答案
是的，定制DSL可以相对容易地在Cadence/Temporal上实现。基本思想是，时态工作流定义是代码，您必须使用该代码编写一个简单的DSL解释器。由于代码具有容错性和持久性，DSL将获得Cadence / Temporal的所有好处。
下面是一个使用Go SDK的DSL示例。稍后我们将添加Java。
-
在Cadence/Temoral工作流编程中： < li >不允许使用本机线程库。例如，在Java中，线程必须通过< code>Async.procedure或< code>Async.function创建，而在Golang中，线程必须通过< code>workflow创建。去吧。那为什么呢？ < li >有没有类似使用本机线程的竞争条件？例如，为了线程安全，应该使用< code>Hashtabl
-
Cadence使用tally发出一堆指标。可以使用Cadence SDK发出我自己的指标吗？ Go SDK有，但当我刚刚调用它时，它似乎不起作用。我是否缺少一些必需的配置？
-
当使用像文档建议的那样的信号时： 我可能会遇到以下问题: 我想保证一次处理一个FIFO 我想处理signalWithStart的“赛车状态”，其中信号方法调用得太早 我想安全地重置工作流。重置后，可以在历史早期重新应用信号 我想确保工作流不会在信号处理之前提前完成
-
假设我有用不同语言编写的工人（Java
-
问题内容： 我正在使用以Python编写的mapper和reducer在Hadoop中（在Amazon EMR上）运行流作业。我想知道如果我在Java中实现相同的mapper和reducer（或使用Pig），将会获得的速度提升。 特别是，我正在寻找人们从流媒体迁移到自定义jar部署和/或Pig的经验，以及包含这些选项的基准比较的文档。我找到了这个问题，但是答案对我来说不够具体。我不是要在Java和
-
将是什么 线程不足，无法执行工作流。如果此消息始终显示，请选择WorkerOptions。应减小maxConcurrentWorklfowExecutionSize或WorkerOptions。maxWorkflowThreads增加。 处于阻塞状态的工作流在内存中保持活动状态？？处于等待状态的工作流是否持续检查条件？？更多的 -