def create_bulker(self):
return self.bulker_class(self, bulk_size=self.bulk_size,<EOL>raise_on_bulk_item_failure=self.raise_on_bulk_item_failure)<EOL>
Create a bulker object and return it to allow to manage custom bulk policies