diff --git a/CONTRIBUTORS b/CONTRIBUTORS
--- a/CONTRIBUTORS
+++ b/CONTRIBUTORS
@@ -1,3 +1,4 @@
 Daniele Serafini
 Ishan Bhanuka
+Kumar Shivendu
 Quentin Campos
diff --git a/swh/storage/cassandra/storage.py b/swh/storage/cassandra/storage.py
--- a/swh/storage/cassandra/storage.py
+++ b/swh/storage/cassandra/storage.py
@@ -192,7 +192,10 @@
         return summary
 
     def content_add(self, content: List[Content]) -> Dict:
-        contents = [attr.evolve(c, ctime=now()) for c in content]
+        to_add = {
+            (c.sha1, c.sha1_git, c.sha256, c.blake2s256): c for c in content
+        }.values()
+        contents = [attr.evolve(c, ctime=now()) for c in to_add]
         return self._content_add(list(contents), with_data=True)
 
     def content_update(
@@ -354,8 +357,9 @@
                 yield {algo: content[algo] for algo in DEFAULT_ALGORITHMS}
 
     def directory_add(self, directories: List[Directory]) -> Dict:
+        to_add = {d.id: d for d in directories}.values()
         # Filter out directories that are already inserted.
-        missing = self.directory_missing([dir_.id for dir_ in directories])
+        missing = self.directory_missing([dir_.id for dir_ in to_add])
         directories = [dir_ for dir_ in directories if dir_.id in missing]
 
         self.journal_writer.directory_add(directories)
@@ -479,7 +483,8 @@
 
     def revision_add(self, revisions: List[Revision]) -> Dict:
         # Filter-out revisions already in the database
-        missing = self.revision_missing([rev.id for rev in revisions])
+        to_add = {r.id: r for r in revisions}.values()
+        missing = self.revision_missing([rev.id for rev in to_add])
         revisions = [rev for rev in revisions if rev.id in missing]
         self.journal_writer.revision_add(revisions)
 
@@ -589,20 +594,16 @@
         return revision.id
 
     def release_add(self, releases: List[Release]) -> Dict:
-        to_add = []
-        for rel in releases:
-            if rel not in to_add:
-                to_add.append(rel)
+        to_add = {r.id: r for r in releases}.values()
         missing = set(self.release_missing([rel.id for rel in to_add]))
-        to_add = [rel for rel in to_add if rel.id in missing]
-
-        self.journal_writer.release_add(to_add)
+        releases = [rel for rel in to_add if rel.id in missing]
+        self.journal_writer.release_add(releases)
 
-        for release in to_add:
+        for release in releases:
             if release:
                 self._cql_runner.release_add_one(converters.release_to_db(release))
 
-        return {"release:add": len(to_add)}
+        return {"release:add": len(releases)}
 
     def release_missing(self, releases: List[Sha1Git]) -> Iterable[Sha1Git]:
         return self._cql_runner.release_missing(releases)
@@ -622,7 +623,8 @@
         return release.id
 
     def snapshot_add(self, snapshots: List[Snapshot]) -> Dict:
-        missing = self._cql_runner.snapshot_missing([snp.id for snp in snapshots])
+        to_add = {s.id: s for s in snapshots}.values()
+        missing = self._cql_runner.snapshot_missing([snp.id for snp in to_add])
         snapshots = [snp for snp in snapshots if snp.id in missing]
 
         for snapshot in snapshots:
@@ -892,16 +894,15 @@
         )
 
     def origin_add(self, origins: List[Origin]) -> Dict[str, int]:
-        to_add = [ori for ori in origins if self.origin_get_one(ori.url) is None]
-        # keep only one occurrence of each given origin while keeping the list
-        # sorted as originally given
-        to_add = sorted(set(to_add), key=to_add.index)
-        self.journal_writer.origin_add(to_add)
-        for origin in to_add:
+        to_add = {o.url: o for o in origins}.values()
+        origins = [ori for ori in to_add if self.origin_get_one(ori.url) is None]
+
+        self.journal_writer.origin_add(origins)
+        for origin in origins:
             self._cql_runner.origin_add_one(
                 OriginRow(sha1=hash_url(origin.url), url=origin.url, next_visit_id=1)
             )
-        return {"origin:add": len(to_add)}
+        return {"origin:add": len(origins)}
 
     def origin_visit_add(self, visits: List[OriginVisit]) -> Iterable[OriginVisit]:
         for visit in visits: