Mulesoft Dataweave 转换为 MongoDB - 转换失败 "com.mulesoft.weave.mule.WeaveMessageProcessor$WeaveOutputHandler"
Mulesoft Dataweave transformation into MongoDB - Failed to transform "com.mulesoft.weave.mule.WeaveMessageProcessor$WeaveOutputHandler"
我正在从我的 Alfresco ECM 实例中成功检索记录。当我尝试将它们推入 MongoDb 时,我得到以下信息:
无法从 "com.mulesoft.weave.mule.WeaveMessageProcessor$WeaveOutputHandler" 转换为 "org.bson.Document" (org.mule.api.transformer.TransformerException)。消息负载的类型为:WeaveMessageProcessor$WeaveOutputHandler
我正在使用 Dataweave 将查询记录转换为 Json,但我不确定为什么会这样。
这是我的流程:
<flow name="mongotestFlow">
<http:listener config-ref="HTTP_Listener_Configuration" path="/add" doc:name="HTTP"/>
<cmis:query config-ref="CMIS__Configuration" statement="SELECT cmis:objectId,cmis:name,cmis:contentStreamLength,cmis:creationDate,cmis:lastModifiedBy, cmis:lastModificationDate from cmis:document where cmis:createdBy <> 'System'" doc:name="CMIS"/>
<dw:transform-message doc:name="Transform Message">
<dw:set-payload><![CDATA[%dw 1.0
%output application/json
---
payload.properties map {
"size": $.values[2][0]
}
]]></dw:set-payload>
</dw:transform-message>
<mongo:insert-document config-ref="Mongo_DB__Configuration" collection="testCollection" doc:name="Mongo DB" document-ref="#[message.payload]"/>
</flow>
如有任何帮助,我们将不胜感激。
-S
在插入 Mongo
之前使用 <mongo:json-to-dbobject doc:name="Mongo DB"/>
我正在从我的 Alfresco ECM 实例中成功检索记录。当我尝试将它们推入 MongoDb 时,我得到以下信息:
无法从 "com.mulesoft.weave.mule.WeaveMessageProcessor$WeaveOutputHandler" 转换为 "org.bson.Document" (org.mule.api.transformer.TransformerException)。消息负载的类型为:WeaveMessageProcessor$WeaveOutputHandler
我正在使用 Dataweave 将查询记录转换为 Json,但我不确定为什么会这样。
这是我的流程:
<flow name="mongotestFlow">
<http:listener config-ref="HTTP_Listener_Configuration" path="/add" doc:name="HTTP"/>
<cmis:query config-ref="CMIS__Configuration" statement="SELECT cmis:objectId,cmis:name,cmis:contentStreamLength,cmis:creationDate,cmis:lastModifiedBy, cmis:lastModificationDate from cmis:document where cmis:createdBy <> 'System'" doc:name="CMIS"/>
<dw:transform-message doc:name="Transform Message">
<dw:set-payload><![CDATA[%dw 1.0
%output application/json
---
payload.properties map {
"size": $.values[2][0]
}
]]></dw:set-payload>
</dw:transform-message>
<mongo:insert-document config-ref="Mongo_DB__Configuration" collection="testCollection" doc:name="Mongo DB" document-ref="#[message.payload]"/>
</flow>
如有任何帮助,我们将不胜感激。
-S
在插入 Mongo
<mongo:json-to-dbobject doc:name="Mongo DB"/>