Load Data using the batch indexer example

load_wpoi.py

#!/usr/bin/env python3

from redisearch import Client, TextField
import csv

client = Client('WPOI',
        host='localhost',
        password='',
        port=6379
        )

indexer = client.batch_indexer(chunk_size=1000)

client.create_index((
    TextField('TELNUM'),
    TextField('HTTP'),
    ))

phone_chars = ['(', ')', '-', ' ']

with open('./wpoi.csv', encoding='utf-8') as csv_file:
    csv_reader = csv.reader(csv_file, delimiter=',')
    headers = next(csv_reader, None)
    for row in csv_reader:

        indexer.add_document(
            row[0],
            nosave = True,
            TELNUM = ''.join(i for i in row[27] if not i in phone_chars),
            HTTP = row[30],
        )

indexer.commit()