elasticsearch
copied
Update README
@ -24,7 +24,7 @@ from towhee import pipe, ops, DataCollection
query = {'match_all': {}}
es_search = (
pipe.input('index_name', 'query')
.map(('index_name', 'query'), 'res', ops.elasticsearch.search_client(
.map(('index_name', 'query'), 'res', ops.elasticsearch.osschat_search(
host='localhost', port=9200
))
.output('query', 'res')