aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--fatcat/api_client.py9
1 files changed, 6 insertions, 3 deletions
diff --git a/fatcat/api_client.py b/fatcat/api_client.py
index f997f5fc..291b7a1b 100644
--- a/fatcat/api_client.py
+++ b/fatcat/api_client.py
@@ -47,12 +47,12 @@ class FatCatApiClient:
self._issn_map[issn] = container_id
return container_id
- def import_crossref_file(self, json_file, create_containers=False):
+ def import_crossref_file(self, json_file, create_containers=False, batchsize=100):
eg = self.new_editgroup()
i = 0
with open(json_file, 'r') as file:
for line in file:
- if i % 1000 == 0:
+ if i % batchsize == 0:
sys.stdout.write('\n{}: '.format(i))
if (i+1) % 20 == 0:
sys.stdout.write('.')
@@ -65,7 +65,10 @@ class FatCatApiClient:
create_containers=create_containers)
except Exception as e:
print("ERROR: {}".format(e))
- if i % 1000 != 0:
+ if i % batchsize == 0:
+ self.accept_editgroup(eg)
+ eg = self.new_editgroup()
+ if i % batchsize != 0:
self.accept_editgroup(eg)
print("done!")