Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/postgresql/storage.py
Show First 20 Lines • Show All 1,236 Lines • ▼ Show 20 Lines | ) -> None: | ||||
metadata = list(metadata) | metadata = list(metadata) | ||||
self.journal_writer.raw_extrinsic_metadata_add(metadata) | self.journal_writer.raw_extrinsic_metadata_add(metadata) | ||||
counter = Counter[ExtendedObjectType]() | counter = Counter[ExtendedObjectType]() | ||||
for metadata_entry in metadata: | for metadata_entry in metadata: | ||||
authority_id = self._get_authority_id(metadata_entry.authority, db, cur) | authority_id = self._get_authority_id(metadata_entry.authority, db, cur) | ||||
fetcher_id = self._get_fetcher_id(metadata_entry.fetcher, db, cur) | fetcher_id = self._get_fetcher_id(metadata_entry.fetcher, db, cur) | ||||
db.raw_extrinsic_metadata_add( | db.raw_extrinsic_metadata_add( | ||||
id=metadata_entry.id, | |||||
type=metadata_entry.target.object_type.name.lower(), | type=metadata_entry.target.object_type.name.lower(), | ||||
target=str(metadata_entry.target), | target=str(metadata_entry.target), | ||||
discovery_date=metadata_entry.discovery_date, | discovery_date=metadata_entry.discovery_date, | ||||
authority_id=authority_id, | authority_id=authority_id, | ||||
fetcher_id=fetcher_id, | fetcher_id=fetcher_id, | ||||
format=metadata_entry.format, | format=metadata_entry.format, | ||||
metadata=metadata_entry.metadata, | metadata=metadata_entry.metadata, | ||||
origin=metadata_entry.origin, | origin=metadata_entry.origin, | ||||
▲ Show 20 Lines • Show All 151 Lines • Show Last 20 Lines |