es_tribler_search.py

import sys

from elasticsearch import Elasticsearch

elastic_client = Elasticsearch('http://localhost:9200', request_timeout=120)

print('query:')
for line in sys.stdin:
    query = {
        "simple_query_string": {
            "query": line.rstrip(),
        }
    }

    result = elastic_client.search(index='tribler', query=query, size=50)
    print(f'\nResults({result.body["took"] / 1000}s):')
    printed_infohashes = set()
    for hit in result.body['hits']['hits']:
        infohash = hit['_source']['infohash']
        if infohash in printed_infohashes:
            continue
        print(f"{hit['_source']['title']} [score: {hit['_score']} infohash: {infohash}]")
        printed_infohashes.add(infohash)

    print('\nquery:')