Mule Salesforce Batch 中的错误处理

2024-02-18

我正在尝试将一组帐户从 CSV 文件加载到 Salesforce 中。我已经配置了常用的 Datamapper、带有批提交的 Upsert SFDC 步骤和仅处理失败的批步骤(目前为日志)。我的 OnComplete 有一个简单的记录器。我故意创建了包含错误数据的 CSV。我在 CSV 中有一个外部 ID。

我的要求是根据失败状态对失败记录进行不同的处理。如果由于错误数据而失败,我想停止处理记录。如果由于找不到父密钥而失败,我想重试。我的批处理步骤仅出现错误,不知道为什么失败。不知何故,我想将“为什么失败”传递给我的失败处理步骤。

我确信这是一个简单的模式,但我无法弄清楚如何关联:(


In <batch:step name="Handle Failure" accept-policy="ONLY_FAILURES"/>您可以使用#[getStepException()]MEL来获取异常Map。之后你可以根据你想要处理的逻辑使用选择组件。参考:http://blogs.mulesoft.com/dev/mule-dev/handle-errors-batch-job/ http://blogs.mulesoft.com/dev/mule-dev/handle-errors-batch-job/

确保使用<batch:job name="BatchFlow" max-failed-records="-1">,最大失败记录设置为-1,这样流程就不会停止,如果任何记录中发生故障,它会将其传递给“仅失败”流程。

  <batch:job name="BatchFlow" max-failed-records="-1">
    <batch:process-records>
        <batch:step name="Batch_Step">
        <!-- Success flow... -->

        </batch:step>
        <batch:step name="Handle Failure" accept-policy="ONLY_FAILURES">
            <logger message="Details:#[getStepException()]" level="INFO" doc:name="Logger"/>
           <!--  other logic  -->

        </batch:step>
    </batch:process-records>
</batch:job>
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Mule Salesforce Batch 中的错误处理 的相关文章

  • 从 JSR 352 中的分区步骤访问作业上下文

    我正在尝试在批处理之间传递对象 但在尝试从分区步骤 批处理 访问 jobContext 时遇到了问题 根据 JSR 352 规范 9 4 1 1 批处理上下文生命周期和范围 批处理上下文具有线程关联性 并且仅对批处理可见 在该特定线程上执行
  • 搜索文件中的单词列表,然后在另一个文件中找到这些单词,将整行替换为 Class=ShipDummy,替换其下面的 2 行

    我想从外部列表 简单地一行中的每个单词 中搜索单词列表 我们将其称为 List txt 并在文件中搜索它们 C Users P Ditty 文件 SH3 data cfg Backups SCR clg 匹配整个单词 即使它在另一个单词中
  • 在 Windows 操作系统上批量运行多个 m 文件,“无需”关闭先前运行的 m 文件

    我的目的是顺序运行一系列m文件和python程序 感谢 Mofi Shai 和 moarningsun 我发现这个批处理文件在我的 Windows 操作系统上是成功的 start 01 wait C Program Files MATLAB
  • 如何在 Mule 中添加一次全局异常处理程序/记录器

    我们想要向 mule 添加几行 XML 配置 并使用一个异常处理程序来记录到 SLF4J 而不是现在记录的位置 stdout 我们如何添加这个 我们不想将此处理程序添加到每个流 50 多个流 加上人们添加流时 他们可能会忘记添加我们的异常处
  • Mule 流程:如何从 XML 文件中删除 BOM 标记

    我已经为 Mule 流程输入了复杂的大型 XML 文件 文件结束点 gt 字节数组到字符串 gt 分割器 gt 我有org xml sax SAXParseException 序言中不允许有内容当我尝试使用 Splitter 组件处理输入文
  • 如何在骡子中手动抛出肥皂故障

    我面临着一种情况 我们无法使用模式来验证传入的请求 基本上模式就在那里 但它接受请求中的任何字符串 wsdl 设计者有自己的理由这样做 以接受来自不同来源和灵活性的请求 但是 当收到请求时 我会验证请求包装器的子元素是否是我们所期望的 为此
  • 使用groovy Sql批量插入?

    如何在模拟准备好的语句时使用 groovy Sql 进行批量插入 我发现的所有示例都与以下类似 并且不使用准备好的语句 withBatch stmt gt stmt addBatch insert into table field1 fie
  • 识别批处理文件的运行实例

    这些对我不起作用 有什么帮助可以明确纠正以下四个示例吗 即使我打开了三个 CMD exe EXAMPLE01 也只是回显 继续 示例 01 echo off wmic process where name cmd exe find cmd
  • Mule http:outbound-endpoint + multipart/form-data

    我正在尝试调用一个期望接收多部分 表单数据的休息服务 但我遇到了一些问题 经过一段时间的搜索 我了解到我必须将有效负载移动到出站附件并将有效负载设置为空
  • Google Translation API id 因请求过多而阻止 IP 地址

    我正在设置一个Django从 API 请求产品数据的视图 使用以下命令解析它们BeautifulSoup 应用googletrans模块并将响应保存到我的 Postgresql 数据库中 昨天一切都工作正常 直到突然 Google 阻止了对
  • 为什么 Spring Boot Batch 作业只运行一次?

    我正在使用弹簧靴 我有一个用这些类实现的批处理作业 我的主要课程是 SpringBootApplication ComponentScan com batch PropertySource classpath application pro
  • 如何在Mule中创建独占队列消费者?

    在 ActiveMQ 中 您可以为队列配置独占消费者 例如 Queue Name Here consumer exclusive true 如何在 Mule 中配置像上面这样的独占消费者 您需要对队列名称进行 URL 编码 因为 Mule
  • 在 osx 上批量将 .py(文本文件)转换为 .pdf

    我教授 Python 课程 并且有大量提交用于考试的 py 文件 我想将所有这些内容转换为 pdf 以便我可以在 ipad 上的 IAnnotate 中打开它们 对其进行标记并将其返回给学生 我怎样才能在批处理模式下进行这样的转换 在小牛队
  • 读取通配符文件名的 Quartz 作业仅获取一个文件

    使用骡子 3 7 如果我的目录中有 5 个扩展名为 csv 的文件 则以下代码仅选取这五个文件之一 如果我删除石英触发器并将其设为普通文件 inbound endpoint 它将拾取所有五个文件 看起来很简单 但并没有按预期工作 Thank
  • Spark作业是什么?

    我已经完成了 Spark 安装并执行了一些设置主节点和工作节点的测试用例 也就是说 我对 Spark 上下文 而不是 SparkContext 中的作业到底意味着什么感到非常困惑 我有以下问题 工作与驱动程序有多么不同 应用程序本身是驱动程
  • 批量执行R脚本

    我无法从 Windows 命令行获取脚本 输入以下命令 C Program Files RStudio bin rstudio exe CMD BATCH vanilla slave E myfile R 打开 Rstudio 和相关脚本
  • Mule 中使用日期的 JMS 消息选择器

    在 Mule 3 3 1 中 在异步处理期间 当我的任何外部服务关闭时 我想将消息放在队列中 retryQueue 具有特定的 下次重试 时间戳 处理来自此的消息的流程retryQueue根据 下次重试 时间选择消息 如果 下次重试 时间超
  • 配置 Mule JPA 模块以使用 Eclipse Link 和 MySQL

    我正在尝试编写一个 Mule ESB 应用程序 它将 XML 文件读入域对象 然后使用 JPA 将该对象写入 MySQL 数据库 我已经弄清楚了大部分所需的配置 但我遇到了一个问题 其中 Mule JPA 模块 https github c
  • 更新 DynamoDB 中的多条记录

    如何在单个查询中更新 DynamoDB 中的多条记录 我有一个 csv 文件作为基于 csv 文件的输入 我必须更新数据库中的多条记录 只有一个属性 有可用的 API 吗 或者这可以使用批处理 Spring batch 来完成 Dynamo
  • Spring Batch - ItemStreamException:未创建输出文件

    我在多线程步骤中定义了以下 FlatFileItemWriter public FlatFileItemWriter

随机推荐