standardize elasticsearch.py to match data sink interface