es-pandas 0.0.1

Read, write and update large scale pandas DataFrame with ElasticSearch

es_pandas

Read, write and update large scale pandas DataFrame with ElasticSearch.

Requirements

This package should work on both python3(>=3.4). ElasticSearch should be version 6.x or 7.x(>=6.8).

Usage

import pandas as pd
import numpy as np
from es_pandas import to_pandas, to_es


# Information of es cluseter
es_host = 'localhost:9200'
index = 'demo'

# Example data frame
df = pd.DataFrame({'Alpha': [chr(i) for i in range(97, 128)], 
                    'Num': [x for x in range(31)], 
                    'Date': pd.date_range(start='2019/01/01', end='2019/01/31')})

# Example of write data to es, auto create and put template to es if template does not exits
to_es(df, es_host, index)

# Example of read data from es
df = to_pandas(es_host, index)
print(df.head())

License

(c) 2019 Frank