elasticsearch
copied
Update README
@ -31,7 +31,7 @@ example_doc = {
es_insert = (
pipe.input('index_name', 'doc')
.map(('index_name', 'doc'), 'res', ops.elasticsearch.index_client(
.map(('index_name', 'doc'), 'res', ops.elasticsearch.osschat_index(
host='localhost', port=9200
))
.output('doc', 'res')