mirror of
https://github.com/Unstructured-IO/unstructured.git
synced 2025-11-04 12:03:15 +00:00
0c834517d8
change opensearch port to see if fixes CI. We think there may be a conflict with the elasticsearch docker port. Also adding simple retry to vector query. --------- Co-authored-by: potter-potter <david.potter@gmail.com>
25 lines
695 B
Python
25 lines
695 B
Python
#!/usr/bin/env python3
|
|
|
|
from opensearch_cluster_config import (
|
|
INDEX_NAME,
|
|
mappings,
|
|
)
|
|
from opensearchpy import OpenSearch
|
|
|
|
print("Connecting to the OpenSearch cluster.")
|
|
client = OpenSearch(
|
|
hosts=[{"host": "localhost", "port": 9247}],
|
|
http_auth=("admin", "admin"),
|
|
use_ssl=True,
|
|
verify_certs=False,
|
|
ssl_show_warn=False,
|
|
)
|
|
print(client.info())
|
|
|
|
print("Creating an OpenSearch index for testing ingest opensearch destination connector.")
|
|
response = client.indices.create(index=INDEX_NAME, body=mappings)
|
|
if not response["acknowledged"]:
|
|
raise RuntimeError("failed to create index")
|
|
|
|
print("Succesfully created an OpenSearch index for testing opensearch ingest.")
|