Перетворення Mulesoft Dataweave в MongoDB - Не вдалося перетворити "com.mulesoft.weave.mule.WeaveMessageProcessor $ WeaveOutputHandler" - java, mongodb, mule, mule-component

Я успішно отримую записи з мого екземпляра 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 &lt;&gt; "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>

Будь-яка допомога буде вдячна.

-С

Відповіді:

Використовуйте <mongo:json-to-dbobject doc:name="Mongo DB"/> перед тим як вставляти в Mongo