def main(batch_size=10000): posts_df = pd.read_hdf('nw_posts.hdf5', 'posts') index_posts_in_elastic(posts_df, batch_size=batch_size)