Create a data source for the given importer and store the data retrieved in the database.
(self)
| 52 | self.importer_class = importer_class |
| 53 | |
| 54 | def run(self) -> None: |
| 55 | """ |
| 56 | Create a data source for the given importer and store the data retrieved in the database. |
| 57 | """ |
| 58 | importer_name = self.importer_class.qualified_name |
| 59 | importer_class = self.importer_class |
| 60 | logger.info(f"Starting import for {importer_name}") |
| 61 | advisory_datas = importer_class().advisory_data() |
| 62 | count = self.process_advisories(advisory_datas=advisory_datas, importer_name=importer_name) |
| 63 | logger.info(f"Finished import for {importer_name}. Imported {count} advisories.") |
| 64 | |
| 65 | def do_import(self, advisories) -> None: |
| 66 | advisory_importer = DefaultImporter(advisories=advisories) |