Change rabbitMQ input plugin to be able to handle different messages

cedadev / stac-generator

Wrapper package to scan assets for metadata and facets to generate catalogue items. Provides IO packages

Other

3 stars 5 forks source link

Closed rsmith013 closed 1 week ago

rsmith013 commented 2 years ago

At the moment it creates an IngestMessage Object, we need to be able to handle different message structures.

Just create a dictionary and **kwarg splatter them into the main code.

Mahir-Sparkess commented 2 years ago

https://github.com/cedadev/asset-scanner/pull/28
Added rabbit mq output:
- takes data and optional kwargs for x-delay
- publishes data, and creates properties with the header kwargs.
Change rabbit mq input:
- decode to just a dict instead of an ingest message. (does this break something else?)
- message splatter to process_file. decoded message should have args like object_id, filepath, source_media.