mule 4.4数据拖曳附加柜台的文件

Question

我在文件中阅读（请参阅下文）。示例文件有13行。

A|doe|chemistry|100|A|
B|shea|maths|90|A|
C|baba|physics|80|B|
D|doe|chemistry|100|A|
E|shea|maths|90|A|
F|baba|physics|80|B|
G|doe|chemistry|100|A|
H|shea|maths|90|A|
I|baba|physics|80|B|
J|doe|chemistry|100|A|
K|shea|maths|90|A|
L|baba|physics|80|B|
M|doe|chemistry|100|A|

然后使用每个（批次尺寸5）在这些行上迭代，然后调用REST API 根据REST API响应（成功或失败），我正在为相应的成功 /错误文件编写有效载荷。

我嘲笑了所谓的API，使得第5个记录的第一批记录将失败，其余文件将成功。

在写入成功 /错误文件时，我们正在使用以下转换：

output application/csv quoteValues=true,header=false,separator="|"
---
payload

所有这些都可以。
成功日志文件：

"F"|"baba"|"physics"|"80"|"B"
"G"|"doe"|"chemistry"|"100"|"A"
"H"|"shea"|"maths"|"90"|"A"
"I"|"baba"|"physics"|"80"|"B"
"J"|"doe"|"chemistry"|"100"|"A"
"K"|"shea"|"maths"|"90"|"A"
"L"|"baba"|"physics"|"80"|"B"
"M"|"doe"|"chemistry"|"100"|"A"

错误日志文件：

"A"|"doe"|"chemistry"|"100"|"A"
"B"|"shea"|"maths"|"90"|"A"
"C"|"baba"|"physics"|"80"|"B"
"D"|"doe"|"chemistry"|"100"|"A"
"E"|"shea"|"maths"|"90"|"A"

现在我想做的是将行/行号附加到这些文件中的每个文件中，因此，当它用于生产时，任何正在监视这些文件的人都可以轻松地理解并与原始文件相关。 因此，作为错误日志文件的一个例子（第一个批次失败，是第1至5行），我想将这些数字附加到每个行：

"1"|"A"|"doe"|"chemistry"|"100"|"A"
"2"|"B"|"shea"|"maths"|"90"|"A"
"3"|"C"|"baba"|"physics"|"80"|"B"
"4"|"D"|"doe"|"chemistry"|"100"|"A"
"5"|"E"|"shea"|"maths"|"90"|"A"

不确定我应该在DataWeave中写的是什么来实现这一目标？

Answer 1

在 ForEach 范围内，您可以访问计数器 vars.counter （或您选择的任何名称，因为它是可配置的）。
您将需要迭代每个记录块以添加每个记录的位置。您可以使用以下内容：

%dw 2.0
output application/csv quoteValues=true,header=false,separator="|"
var batchSize = 5
---
payload map ({
    counter: batchSize * (vars.counter - 1) + ($ + 1)
} ++ $
)

或者如果您更喜欢使用 update 函数（这会在最后一列添加记录计数器）：

%dw 2.0
output application/csv quoteValues=true,header=false,separator="|"
var batchSize = 5
---
payload map (
    $ update {
        case .counter! -> batchSize * (vars.counter - 1) + ($ + 1)
    }
)

请记住替换 batchSize 变量从此代码中使用与 ForEach 范围中使用的相同值（如果它是参数化的，那就更好了）。

编辑 1 -
澄清： - 1 和 + 1 是因为两个索引（来自 For Each 范围的计数器和 $$map 中的 code> ）是从零开始的。

Answer 2

只是另一个解决方法，并在不使用任何外部变量的情况下简化。脚本可以分为两；第一是错误组，第二是成功。

%dw 2.0
output application/csv quoteValues=true,header=false,separator="|"
// Will be used for creating a counter for Error group
var errorIdx = 1  
 // Will be used for creating a counter for Success group
var successIdx = 6
---
//errorItems for the first 5 rows
(payload[0 to 4] map (items,idx) -> (({"0":(idx) + errorIdx} ++ items))) 

++

//successItems from 6 and remaining items.
(payload[5 to -1] map (items,idx) -> (({"0":(idx) + successIdx} ++ items))) 

dataweave内联变量：

• 的指针
• errorIdx 是启动错误计数器 Scuctidx is 一个用于启动成功计数器的指针

这将从索引0到4元素提取：

payload[0 to 4]

这将从索引5提取到其余元素：

payload[5 to -1]