This commit is contained in:
parent
fd50baa0dc
commit
90b841ddcc
@ -60,10 +60,12 @@ def main():
|
|||||||
logging.basicConfig(level=logging.DEBUG)
|
logging.basicConfig(level=logging.DEBUG)
|
||||||
args = parse_args()
|
args = parse_args()
|
||||||
|
|
||||||
|
logging.debug("Obtaining data from otc_metadata")
|
||||||
data = getData(
|
data = getData(
|
||||||
environment=args.target_environment
|
environment=args.target_environment
|
||||||
)
|
)
|
||||||
|
|
||||||
|
logging.debug("Indexing data into OpenSearch")
|
||||||
indexData(
|
indexData(
|
||||||
deleteIndex=args.delete_index,
|
deleteIndex=args.delete_index,
|
||||||
hosts=args.hosts,
|
hosts=args.hosts,
|
||||||
@ -93,9 +95,12 @@ def indexData(deleteIndex, hosts, index, username, password, data):
|
|||||||
)
|
)
|
||||||
|
|
||||||
if deleteIndex is True:
|
if deleteIndex is True:
|
||||||
|
logging.debug("Deleting Index")
|
||||||
delete_index(client, index)
|
delete_index(client, index)
|
||||||
|
|
||||||
|
logging.debug("Started creating Index")
|
||||||
create_index(client, index, data)
|
create_index(client, index, data)
|
||||||
|
logging.debug("Finished creating Index")
|
||||||
|
|
||||||
|
|
||||||
def generate_os_host_list(hosts):
|
def generate_os_host_list(hosts):
|
||||||
@ -116,3 +121,6 @@ def create_index(client, index, data):
|
|||||||
|
|
||||||
def delete_index(client, index):
|
def delete_index(client, index):
|
||||||
return client.indices.delete(index=index, ignore=[400, 404])
|
return client.indices.delete(index=index, ignore=[400, 404])
|
||||||
|
|
||||||
|
|
||||||
|
main()
|
Loading…
x
Reference in New Issue
Block a user