mirror of
https://github.com/status-im/infra-utils.git
synced 2025-02-23 01:18:08 +00:00
elasticsearch/esclean.py: add missing schema argument
Fixes: ``` TypeError: __init__() missing 1 required positional argument: 'scheme' ``` Signed-off-by: Jakub Sokołowski <jakub@status.im>
This commit is contained in:
parent
34e5d068a4
commit
5dc408f866
@ -34,7 +34,7 @@ def parse_opts():
|
||||
help='Delete matching documents.')
|
||||
parser.add_option('-q', '--query', type='str',
|
||||
help='Query matching documents.')
|
||||
|
||||
|
||||
return parser.parse_args()
|
||||
|
||||
def print_logs(docs):
|
||||
@ -53,16 +53,15 @@ def main():
|
||||
(opts, args) = parse_opts()
|
||||
|
||||
es = Elasticsearch(
|
||||
[{ 'host': opts.es_host,
|
||||
'port': opts.es_port }],
|
||||
timeout=1200,
|
||||
hosts=[{ 'host': opts.es_host, 'port': opts.es_port, 'scheme': 'http'}],
|
||||
request_timeout=1200,
|
||||
retry_on_timeout=True
|
||||
)
|
||||
|
||||
|
||||
print('Cluster: {}'.format(es.info().get('cluster_name')))
|
||||
|
||||
|
||||
indices = es.indices.get(index=opts.index_pattern).keys()
|
||||
|
||||
|
||||
queries = []
|
||||
if opts.tag:
|
||||
queries.append({'match': {'tags': opts.tag}})
|
||||
|
Loading…
x
Reference in New Issue
Block a user