首页 文章
  • 5 votes
     answers
     views

    亚马逊SWF:至少有一名 Worker 必须在运营,为什么?

    我刚开始使用AWS Ruby SDK来管理简单的工作流程 . 我立即注意到的一个行为是,在提交新的工作流程执行之前,必须至少运行一个相关工作者和一个相关决策者 . 如果我在启动我的工作者和决策者之前提交新的工作流程执行,那么即使我仍处于超时限制范围内,也永远不会接收任务 . 为什么是这样?根据HTTP长轮询的工作原理,我希望在达到poll()调用时,任一应用程序都会收到相关的任务 . 在作业失败后...
  • 4 votes
     answers
     views

    在Amazon SWF中,我可以滥用Decision任务来实际执行工作

    我需要Amazon SWF来分发一些工作,确保它以可靠的方式存储,并且它会自动重新启动 . 但是,我需要的工作流逻辑非常简单:它只是执行一个任务 . 我现在以它应该完成的方式实现它: 请求工作流程执行 Decider发现了它并安排了一项活动 Worker 发现活动请求,执行结果并返回结果 Decider注意到结果并在工作流程完成时将其复制 在我看来,我可以让决策者完成工作 - ...
  • 3 votes
     answers
     views

    将某些工作流程执行优先于其他工作流程

    我一直在使用amazon swf的流程框架,我希望能够运行优先级工作流程执行和正常的工作流程执行 . 如果存在优先级任务,则活动应在正常优先级任务之前获取优先级任务 . 完成此任务的最佳方法是什么? 我认为以下可能会有效,但我想知道是否有更好/推荐的方法 . 我将为活动定义两个活动工作者和两个活动列表 . 一个优先级列表和一个普通列表 . 每个工作人员将使用相同的活动类 . 两个工作程序将...
  • 5 votes
     answers
     views

    基于SQS消息触发SWF工作流

    Preamble: 我喜欢使用亚马逊's SWF and SQS to accomplish my goals. There may be other services that will better match what I' m尝试做,所以如果你有建议请随意把它们扔出去 . Problem: 最基本的需求是客户端(移动设备,Web服务器等)发布将异步处理而不响应客户端的消息 - 非常基本 ....
  • 0 votes
     answers
     views

    Amazon Simple Workflow和子工作流程

    我正在尝试使用适用于AWS的Java流程框架从amazon简单工作流服务中的工作流运行子工作流 . 以下是主要的工作流程实现代码: package SWF.ChildWorkFlow; import org.springframework.core.annotation.Order; import com.amazonaws.services.simpleworkflow.flow.core....
  • 0 votes
     answers
     views

    Amazon Simple Workflow(SWF)可以与jRuby一起使用吗?

    出于无趣的原因,我必须在特定项目中使用jRuby,我们也希望使用Amazon Simple Workflow(SWF) . 我在jRuby部门没有选择,所以请不要说“使用MRI” . 我遇到的第一个问题是jRuby不支持分叉和SWF活动工作者喜欢分叉 . 在浏览SWF ruby库之后,我能够弄清楚如何连接 Logger 并找出如何防止分叉,这非常有用: AWS::Flow::ActivityWor...
  • 1 votes
     answers
     views

    如何使用PHP集成AWS SWF,以便可以从用户界面进行管理?

    我正在使用LAMP构建一个CMS,允许管理员将MP4上传到Amazon S3 Bucket,使用Elastic Transcoder将其转换几次,并更新本地数据库,以便使用Cloud Front交付它们 . 现在每个步骤都按预期工作,并且一个简单的SWF工作流程将它连接起来(只要我从命令行启动启动器,决策器和活动工作器,就像我在各处的示例中看到的那样) . 但是,我正在努力通过用户界面连接各个部分...
  • 1 votes
     answers
     views

    接近亚马逊瑞士法郎的坠毁 Worker

    我们目前正在Amazon SWF中实施工作流程,我们从Web应用程序提交作业/工作流程执行 . 使用Ruby Flow框架进行设置时,一切都非常快速且轻松 . 只要决策者/活动工作者不崩溃,我们似乎能够优雅地处理大多数问题/异常 . 我的问题是,决策程序进程在工作流执行中途崩溃的情况的常见做法是什么?如果任务以这种方式失败,是否可以推送SNS通知(我没有看到任何示例)或某些东西向另一个进程表明存在...
  • 0 votes
     answers
     views

    如果满足某些前提条件,是否有办法同步完成手动任务(无需等待异步结果)?

    我正在使用AWS SWF和流程框架 . 我想让我的活动具有幂等性,以便在任何失败后从一开始就重新启动工作流程 . 许多活动都是手动任务(@ManualActivityCompletion),需要异步完成 . 如果我知道它已经完成了,有没有办法完成正常任务等手动任务?这样,每次重试工作流时都不会安排新的手动任务 . 或者,有没有办法重试工作流程,使其从失败的角度开始?
  • 18 votes
     answers
     views

    用于短期任务的Amazon EC2按需工作者

    我希望构建一个Web应用程序,它需要在R中按需运行资源密集型MCMC(Markov chain Monte Carlo)计算,以便为用户生成一些概率图 . 约束: 显然,我不想在与Web应用程序前端相同的服务器上运行资源密集型计算,因此需要将这些任务交给 worker instance . 这些计算需要运行大量的CPU,我希望尽可能保持延迟(希望是秒,而不是几分钟),所以我宁愿在 bee...
  • 0 votes
     answers
     views

    Amazon SWF初学者 - 如何开始执行一个工作流程循环

    我正在通过Flow Framework(即Java)查看可用于Amazon SWF的示例 - 在示例中我注意到有一个类具有启动工作流执行的“main” - 还有其他类似的类具有“main”启动工作流工作者和活动工作者(即工作流主机和活动主机) . 这是否意味着要运行工作流,我必须将所有3个类的执行代码放入我的void main中?即我是否必须自己启动工作流主机,活动主持人并启动工作流程?或者我只需...
  • 0 votes
     answers
     views

    aws swf - 从工作流中获取工作流程执行ID

    我正在使用Amazon SWF服务来自动执行一些重复性任务 . 我试图使用 signals 在远程计算机上执行一些命令 . 命令执行完毕后,我想将信号发送回工作流程以指示成功或失败 . 问题是如何以编程方式找到 workflow execution id ?这是远程机器发送 signal 所必需的 . 谢谢
  • 0 votes
     answers
     views

    如何在前一个活动仍在激活时定期安排相同的活动

    我的目标是 Build 一个工作流,定期(每30秒)向taskList添加一个相同的活动(只做1分钟的睡眠) . 此外,我有多台托管活动工作者的机器同时轮询taskList . 当活动安排好后,其中一个工作人员可以轮询并执行 . 我尝试使用cron装饰器来创建DynamicActivityClient,并使用DynamicActivityClient.scheduleActivity()定期调度活...
  • 1 votes
     answers
     views

    AWS Lambda函数未在简单工作流(SWF)中执行

    我们正在创建一个包含多个活动的工作流程 . 其中一项活动是直接调用Lambda函数 . Lambda函数在不使用工作流的情况下正确执行(使用AWS Lambda控制台) . 当使用SWF调用它时,函数不会被调度,也不会抛出任何错误 . Lambda函数的骨架如下 . public String handleRequest(String path, Context context) { ...
  • 1 votes
     answers
     views

    SWF:获取工作流启动程序中所有活动的结果

    我正在和amazon-swf合作 . 我有4个活动 . 它们都是异步的 . 工作流程通过rest api调用从前端启动 . 我想将所有4个活动的结果作为对api调用的响应返回 . 由于@execute方法在从外部客户端调用时无法返回除void之外的任何内容,因此我无法在工作流启动程序中获得所有4个活动的结果 . 解决问题的一种方法是在启动程序中继续轮询工作流历史记录,但我真的不认为这是最佳解决方案...
  • 1 votes
     answers
     views

    AWS SWF连接对当前正在执行的工作流程的影响?

    我很想知道当前正在执行的工作流程中与AWS SWF的连接丢失 . 请有人帮我理解 . 我知道决策者和 Worker 会超时 . 但不确定确切的行为 .
  • 1 votes
     answers
     views

    Amazon SWF在不同工作流程之间共享活动任务

    基本上 Headers 是:我希望不同的工作流能够等待共享任务的完成 . 例如,工作流1需要完成任务A,B和C,而工作流2需要完成任务C,D和E,然后再继续执行其他操作 . 我知道活动具有唯一的ID,因此如果工作流2尝试启动“C”而1已经启动“C”,它将返回ACTIVITY_ID_ALREADY_IN_USE错误并且现在知道启动活动工作者的副本 . 问题是,一旦C完成,我如何通知两个工作流程? 谢...
  • 0 votes
     answers
     views

    AWS SWF(简单工作流程)仅在存在SQS消息时启动,这可能吗?

    我的目标: 我有一个非常简单的工作流程,我想实现 . 给定ID,只有当该文件尚不存在时,才在s3存储桶中创建一个名为ID.txt的文件 . 到目前为止我尝试了什么: 我已阅读doco并使用aws-ruby-flow浏览了一些示例 .到目前为止,总有意义 . 我仍然没有得到: 我的愿望是让工作流程处理包含s的SQS消息 . 我不了解的是当排队的消息出现时如何启动工作流程 . 问题 我是否需要在SQS...
  • 2 votes
     answers
     views

    单元测试活动标记为@ManualActivityCompletion

    我一直致力于创建运行本地版本工作流的单元测试 . 我按照guide进行初始设置 . 通过该设置,我能够成功执行和测试工作流程 . 当我尝试对标记为@ManualActivityCompletion的活动实现进行单元测试时,会出现问题 . 看起来手动完成活动通常在单元测试中返回(不等待完成/失败调用) . 我想知道是否有可能以这种方式进行单元测试手动完成活动 . 我的猜测是,因为我没有看到它,我没有...
  • 0 votes
     answers
     views

    AWS SWF Flow Java Decider

    我们如何在AWS SWF Flow Java框架中编写决策程序 . 提供的所有示例仅涉及活动和工作流程 . 流API具有类似DecisionTaskHandler的类,但我无法使用流框架找到任何Java示例 .
  • 0 votes
     answers
     views

    亚马逊AWS SWF等待信号

    我正在构建一个流程,需要用户在某个时候进行干预 . 我已经阅读了文档,看到我应该使用SWF信号继续通过我的流程 . 我想知道是否有一种方法可以让流程等待没有定时器的信号 . 我用的时候 timer = create_timer_async(30) wait_for_any(timer, @signal_received) activity.activity_one 我的'activity...
  • 0 votes
     answers
     views

    等待信号开始活动(亚马逊工作流程)

    我使用AWS提供的java流程框架构建了一个工作流程 . 我创建了4个活动 . 第一个活动等待信号开始 . 然后使用Promise <>对象同步执行所有活动 . 工作流程实施代码如下 - public class PaginationWorkflowImpl implements PaginationWorkflow { private ManualUploadClient op...
  • 1 votes
     answers
     views

    Amazon SWF并行子工作流执行暂停父工作流

    我试图开始两个并行执行具有不同启动参数的子工作流 . 但是,我注意到只运行了其中一个子工作流程执行 . 由于未调度任务导致父工作流执行停止,导致执行历史记录中没有任何进一步的活动,直到超时为止 . 没有抛出异常或错误,它只是停止做任何事情 . 有趣的是,它始终是完成的第二个子工作流程执行 . 如果父级只运行子工作流的一次执行,则子级成功完成,父级工作流继续完成 . 我怀疑它与同时运行子工作流的多个...
  • 0 votes
     answers
     views

    AWS SWF决策需要很长时间才能从计划到完成

    我们正在尝试 AWS SWF ,我们的决策者 . 活动非常简单,只需根据事件做出决定,然后调用API做一些事情 . 但是,在运行决策者和活动工作人员一段时间后,每天几个小时,我们发现工作流程从 DecisionTaskStarted 到 DecisionTaskCompleted 或 ActivityTaskStarted 到 ActivityTaskCompleted 所需的时间最多可能需要5分...
  • -4 votes
     answers
     views

    适用于Amazon SWF的AWS Flow Framework Hello世界样本

    我需要使用Amazon SWF(简单的工作流webservice)在java中实现Hello world示例应用程序 . 所以请给我这个样本申请的建议 .
  • 1 votes
     answers
     views

    如何处理Amazon SWF信号?

    所以,我有一个场景,我定期调用SignalWorkflowExecution()传递工作流信号请求 . 在我编码的Decider中,我看到它在下一个轮询请求中接收事件历史中的信号(以及在它之后开始的决策任务) . 我的问题是,如何防止第二次处理信号?也就是说,如果我收到信号,然后提交新的活动进行工作,那么信号是否还会出现在事件的历史中?我没有看到将信号与任何后续决策任务相关联的方法,并且不建议在D...
  • 0 votes
     answers
     views

    AWS SWF安排活动

    使用Java Flow Framework for SWF . 是否可以在SWF中安排特定时间的活动?让我们说,发送在2017年10月22日上午9:00运行“sendNotification” . 这些示例允许创建具有延迟的计时器,但不能在指定时间内创建 . 即使我可以根据当前时间戳和需要触发事件的目标时间来计算延迟,但是如何在工作流程执行期间获取当前时间,因为如果您尝试获取当前系统时间工作流决策...
  • 14 votes
     answers
     views

    如何使用Amazon SWF [关闭]

    Amazon SWF今天发布 . 如何最好地使用Java / PHP /等? 当前的SDK支持似乎不包含它 . 我知道它是新的,但有没有人有任何关于如何使用它的好资源,或者我需要在以下任何SDK中实现哪些更改才能立即开始使用? AWS SDK for Java AWS SDK for PHP AWS SDK for Python AWS SDK for Ruby AWS SDK...
  • 3 votes
     answers
     views

    AWS SWF流程框架 - Eclipse AspectJ加载时编织

    有没有人设法让Simple Workflow的AWS SDK示例和Flow Framework正常工作?我按照Eclipse设置说明(http://docs.amazonwebservices.com/amazonswf/latest/awsflowguide/setup.html)来写信,但没有生成任何类 . 因此,我的项目将无法构建,因为整个地方都缺少* Client类 . 我已尝试使用SDK...
  • 0 votes
     answers
     views

    SWF运行ID的范围

    我想知道SWF生成的RUN ID是否是全面唯一的,或者它是否仅对域工作流ID组合是唯一的 . 从本质上讲,如果我想在SWF之外存储工作流状态和其他元数据,那么通过运行ID来关闭数据是否谨慎或者我是否需要由域和工作流ID组成的复合?

热门问题