topic Re: How to recieve data from cMqtt component and process it? in Talend Studio

How to recieve data from cMqtt component and process it?

Anonymous — Sat, 16 Nov 2024 06:14:23 GMT

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

Re: How to recieve data from cMqtt component and process it?

vapukov — Wed, 27 Mar 2019 12:50:47 GMT

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)

Re: How to recieve data from cMqtt component and process it?

Anonymous — Wed, 27 Mar 2019 13:20:41 GMT

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.?

Re: How to recieve data from cMqtt component and process it?

vapukov — Wed, 27 Mar 2019 13:31:42 GMT

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

Re: How to recieve data from cMqtt component and process it?

Anonymous — Mon, 01 Apr 2019 08:23:37 GMT

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