mirror of https://github.com/armbian/build.git
53 lines
1.3 KiB
Python
53 lines
1.3 KiB
Python
|
#!/usr/bin/env python3
|
||
|
|
import json
|
||
|
|
import sys
|
||
|
|
|
||
|
|
from opensearchpy import OpenSearch # pip install opensearch-py
|
||
|
|
|
||
|
|
|
||
|
|
def eprint(*args, **kwargs):
|
||
|
|
print(*args, file=sys.stderr, **kwargs)
|
||
|
|
|
||
|
|
|
||
|
|
# info = get_info_for_one_board(board, all_params)
|
||
|
|
print(json.dumps({}, indent=4, sort_keys=True))
|
||
|
|
|
||
|
|
eprint("Hello")
|
||
|
|
|
||
|
|
# Read JSON from stdin
|
||
|
|
# - should be array of objects
|
||
|
|
# - loop over array and index each obj into OS in to the passed index
|
||
|
|
# read_from_stdin = sys.stdin.read()
|
||
|
|
|
||
|
|
json_object = json.load(sys.stdin)
|
||
|
|
|
||
|
|
eprint("Loaded {} objects from stdin...".format(len(json_object)))
|
||
|
|
|
||
|
|
host = '192.168.66.55'
|
||
|
|
port = 31920
|
||
|
|
|
||
|
|
# Create the OpenSearch client.
|
||
|
|
client = OpenSearch(hosts=[{'host': host, 'port': port}], http_compress=False, use_ssl=False)
|
||
|
|
|
||
|
|
# Create an index with non-default settings.
|
||
|
|
index_name = 'board-vars-build'
|
||
|
|
index_body = {'settings': {'index': {'number_of_shards': 1, 'number_of_replicas': 0}}}
|
||
|
|
|
||
|
|
# Delete the index; remove old data.
|
||
|
|
try:
|
||
|
|
response = client.indices.delete(index=index_name)
|
||
|
|
print('\nDeleting index:')
|
||
|
|
print(response)
|
||
|
|
except:
|
||
|
|
eprint("Failed to delete index {}".format(index_name))
|
||
|
|
|
||
|
|
response = client.indices.create(index_name, body=index_body)
|
||
|
|
print('\nCreating index:')
|
||
|
|
print(response)
|
||
|
|
|
||
|
|
for obj in json_object:
|
||
|
|
# print(obj)
|
||
|
|
response = client.index(index=index_name, body=obj, refresh=True)
|
||
|
|
print('\nAdding document:')
|
||
|
|
print(response)
|