How to recieve data from cMqtt component and process it?

[Anonymous]

How to recieve payload from cmqtt component and process the content from memory.

[vapukov]

Hi,

for begin you could check Talend help - https://help.talend.com/reader/cc0ggqk5mGdagFtNOvz6vA/A8XUgMXaNyx~uG52W564Tw

for start, you could use 2 components:

• ConnectionFactory
• cMQTT

it for begin, but then - too many variants depending from what you need (including DI subjobs)

[Anonymous]

I need to receive the payload as binary data and upload it to s3 bucket with a file name(file name shoud be like test_{currenttimestamp}.gz). I have changed the data using cMap to byte array. What should be the next steps to create the dynamic filename and uploading byte array data to s3.?

[vapukov]

for proper and full answer need to test of course, but I have not right now access to s3

but you can use - cAWSConnection and cAWSS3, filename you could define any

[Anonymous · Accepted solution]

Found the solution. Used cconvertbodyto compnent with byte[].class as target class name. This converted the mqtt body to binary data.