Can I split compressed files into json components in Camel via Spring DSL -

-

in nutshell, need take gzipped file containing json similar example, unzip (i know how that), each json object string , push amq popped webservice. i'm fine of 1 object, receiving file represents array. if array of strings or xml, see how camel processes it, don't see way split json. also, require streaming these files can large. edited try make request clearer, , provide sample json. 

 [ {     "rickenbackerrepair": {         "estimateid": 22788411     },     "repairshop": {         "inspectionsite": {             "inspectiondate": ""         },         "repairfacility": {             "companyidcode": "",             "companyname": "",             "city": "",             "stateprovince": "",             "zippostalcode": "",             "country": ""         },         "repairinformation": {             "guitardateinshop": "",             "guitartimeinshop": "",             "authorizationmemo": "",             "guitartargetcompletiondate": "",             "guitartargetcompletiontime": "",             "guitarcompletiondate": "",             "guitarcompletiontime": ""         },         "locationofguitar": {             "city": "",             "stateprovince": "",             "zippostalcode": "",             "country": ""         }     },       "instrumentidentifier": {         "guitar": {             "claimrelated": {                 "primarypointofimpact": "",                 "secondarypointofimpact": ""             },             "identification": {                 "databaseguitarcode": "",                 "manufacturingstateprovince": "",                 "serialnumber": "",                 "guitarcondition": "",                 "productiondate": "",                 "year": "",                 "model": "",                 "guitartype": "",                 "bodystyle": "",                 "trimcode": "",                 "trimcolor": "",                 "optionslist": ""             }         }     },     "lin": [{         "internalcontrol": {             "lineindicator": ""         },         "part": {             "description": {                 "parttype": "",                 "descriptionjudgmentflag": "",                 "oempartnumber": "",                 "priceincludedindicator": "",                 "alternatepartindicator": "",                 "taxableflag": "",                 "databasepartprice": "",                 "actualpartprice": "",                 "pricejudgmentflag": "",                 "certifiedflag": "",                 "quantity": ""             },             "nonoemsupplier": {                 "companyidcode": "",                 "nonoempartnumber": "",                 "nonoemsupplieruseroverride": "",                 "nonoemsuppliermemo": ""             },             "adjustment": {                 "percent": "",                 "amount": ""             }         },         "labor": {             "description": {                 "type": "",                 "actualhours": "",                 "hoursjudgmentflag": "",                 "typejudgmentflag": ""             },             "miscsublet": {                 "amount": "",                 "subletflag": ""             }         }     }],      "stl": {         "subtotal": [{             "totaltype": "",             "totaltypecode": "",             "subtotaldetail": {                 "taxableamount": ""             }         }]     } }, {     "rickenbackerrepair": {         "estimateid": 22788412     },     "repairshop": {         "inspectionsite": {             "inspectiondate": ""         },         "repairfacility": {             "companyidcode": "",             "companyname": "",             "city": "",             "stateprovince": "",             "zippostalcode": "",             "country": ""         },         "repairinformation": {             "guitardateinshop": "",             "guitartimeinshop": "",             "authorizationmemo": "",             "guitartargetcompletiondate": "",             "guitartargetcompletiontime": "",             "guitarcompletiondate": "",             "guitarcompletiontime": ""         },         "locationofguitar": {             "city": "",             "stateprovince": "",             "zippostalcode": "",             "country": ""         }     },       "instrumentidentifier": {         "guitar": {             "claimrelated": {                 "primarypointofimpact": "",                 "secondarypointofimpact": ""             },             "identification": {                 "databaseguitarcode": "",                 "manufacturingstateprovince": "",                 "serialnumber": "",                 "guitarcondition": "",                 "productiondate": "",                 "year": "",                 "model": "",                 "guitartype": "",                 "bodystyle": "",                 "trimcode": "",                 "trimcolor": "",                 "optionslist": ""             }         }     },     "lin": [{         "internalcontrol": {             "lineindicator": ""         },         "part": {             "description": {                 "parttype": "",                 "descriptionjudgmentflag": "",                 "oempartnumber": "",                 "priceincludedindicator": "",                 "alternatepartindicator": "",                 "taxableflag": "",                 "databasepartprice": "",                 "actualpartprice": "",                 "pricejudgmentflag": "",                 "certifiedflag": "",                 "quantity": ""             },             "nonoemsupplier": {                 "companyidcode": "",                 "nonoempartnumber": "",                 "nonoemsupplieruseroverride": "",                 "nonoemsuppliermemo": ""             },             "adjustment": {                 "percent": "",                 "amount": ""             }         },         "labor": {             "description": {                 "type": "",                 "actualhours": "",                 "hoursjudgmentflag": "",                 "typejudgmentflag": ""             },             "miscsublet": {                 "amount": "",                 "subletflag": ""             }         }     }],      "stl": {         "subtotal": [{             "totaltype": "",             "totaltypecode": "",             "subtotaldetail": {                 "taxableamount": ""             }         }]     } } ]

you should able use jsonpath expression split incoming message (file) , process each element individually.

<route>   <from uri="file://path" />   <split>     <jsonpath>$.</jsonpath>     <to uri="direct:dosomething">   </split> </route>

Comments

Post a Comment

Popular posts from this blog

javascript - gulp-nodemon - nodejs restart after file change - Error: listen EADDRINUSE events.js:85 -

-
i'm running nodejs 0.12.3 - gulp 3.10.8 , gulp-nodemon 2.0.3. gulpfile.js : gulp.task('serve', ['build'], function() { gulp.start('fb-flo'); nodemon({ script: paths.server, env: { 'node_env': 'development' }, // env: { 'node_env': 'production' }, execmap: { 'js': 'node_modules/babel/bin/babel-node --stage 1' //es7 cote server }, delay: '0ms', watch: ['src/shared/', 'src/server/'], ignore: ['src/shared/components'], tasks: function (changedfiles) { var tasks = []; changedfiles.foreach(function (file) { if (path.extname(file) === '.jsx' && !~tasks.indexof('bundlejs')) tasks.push('bundlejs'); if (path.extname(file) === '.less' && !~tasks.indexof('compileless')) tasks.push('compileless'); }); return tasks; } ...
Read more

Fatal Python error: Py_Initialize: unable to load the file system codec. ImportError: No module named 'encodings' -

-
i trying make simple python program opening list of webpages user manually download reports site. don't have previous experience preparing exe files.. , i'm in learning process python coding. of done on windows 7 x64 this python code: #!c:/python34/python.exe -u splinter import * import time import os import csv #---------------------------------- raporty = [] open('../raporty.csv', newline='') csvfile: contents = csv.reader(csvfile, delimiter=' ', quotechar='|') row in contents: r = ', '.join(row) r = r.replace(',','') raporty.append(r) #--not implemented yet zmienne = [] open('../zmienne.csv', newline='') csvfile: contents = csv.reader(csvfile, delimiter=' ', quotechar='|') row in contents: r = ', '.join(row) r = r.replace(',','') zmienne.append(r) print("start") browser = browser(...
Read more

oracle - Changing start date for system jobs related to automatic statistics collections in 11g -

-
i have oracle database 11g enterprise edition release 11.2.0.1.0 - 64bit production running on windows 2008 r2 somehow got next run dates scheduled jobs set dates in year 2016. jobs created able reset start_date in turn caused next_run_date reset. jobs related oracle automatic statistics collections unable dms_scheduler.set_attribute work changing start_date values. i tried resetting weekly window's dates per oracle document id 1450173.1 using sql following , did in fact reset values see within dba_scheduler_windows had no change dba_scheduler_jobs begin dbms_scheduler.set_attribute ( name => '"sys"."monday_window"', attribute => 'start_date', value => '10-jun-15 10.00.00.000000000 pm us/central'); end; / the job names seeing issue on are: rse$clean_recoverable_script ora$autotask_clean purge_log sm$clean_auto_split_merge bsln_maintain_stats_job mgmt_stats_config_job some of lack schedule names if try dbms_schedul...
Read more