我有一个流,我已经分离了它的一部分,可以重复使用。我已将现有流中的流引用添加到新流,但在使用有效负载进入新流时更改为的数据类型时遇到问题。
新流程由一个 for each 循环组成,该循环将有效负载写入数据库,当有效负载进入与 for each 循环不兼容的新流程时,有效负载将更改为 ByteArraySeekableStream 数据类型。
我需要将 ByteArraySeekableStream 有效负载转换为与 for each 循环兼容的数据类型,然后能够在将有效负载写入数据库之前将其转换回原始 JSON 数据类型。
我怎样才能做到这一点?
目前我尝试过的组合没有奏效,它要么在 for each 循环中失败,要么我无法将有效负载改回 JSON