Added method to add data to fbi-index

cedadev · Apr 18, 2019 · 72169bb · 72169bb
1 parent 666195a
commit 72169bb
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/ceda_elasticsearch_tools/index_tools/index_updaters.py b/ceda_elasticsearch_tools/index_tools/index_updaters.py
@@ -580,8 +580,13 @@ class CedaFbi(IndexUpdaterBase):
     def __init__(self, host_url, index="ceda-fbi", **kwargs):
         super(CedaFbi, self).__init__(index, host_url, **kwargs)
 
-    def add_files(self):
-        pass
+    def add_files(self, files):
+
+        # Generate action list
+        bulk_operations = self._generate_bulk_operation_body(files, type=self.type)
+
+        # Perform bulk action
+        return self._bulk_action(bulk_operations)
 
     def delete_files(self, files):
         """

diff --git a/setup.py b/setup.py
@@ -24,7 +24,7 @@
     # the version across setup.py and the project code, see
     # https://packaging.python.org/en/latest/single_source_version.html
 
-    version='0.4.0',
+    version='0.4.1',
 
     description='Extension of the basic elasticsearch python wrapper to perform operations with a given ES index.',
     long_description=long_description,