Skip to content

Commit ec6d77d

Browse files
Zhangxunmtakolarkunnu
authored andcommitted
fix the tutorial in AIConnectorHelper when fetching domain_url (opensearch-project#3852)
* fix the tutorial in AIConnectorHelper when fetching domain_url Signed-off-by: Xun Zhang <xunzh@amazon.com> * fix for deepseek notebook Signed-off-by: Xun Zhang <xunzh@amazon.com> --------- Signed-off-by: Xun Zhang <xunzh@amazon.com>
1 parent aac8e96 commit ec6d77d

File tree

2 files changed

+29
-2
lines changed

2 files changed

+29
-2
lines changed

docs/tutorials/aws/AIConnectorHelper.ipynb

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,9 +37,22 @@
3737
" domain_info = response['DomainStatus']\n",
3838
"\n",
3939
" # Extract the domain URL and ARN\n",
40-
" domain_url = domain_info['Endpoint']\n",
4140
" domain_arn = domain_info['ARN']\n",
4241
"\n",
42+
" # Check if domain has VPC endpoints\n",
43+
" if 'Endpoints' in domain_info:\n",
44+
" # VPC domain case\n",
45+
" if 'vpc' in domain_info['Endpoints']:\n",
46+
" domain_url = domain_info['Endpoints']['vpc']\n",
47+
" else:\n",
48+
" domain_url = next(iter(domain_info['Endpoints'].values()))\n",
49+
" # Non-VPC domain case\n",
50+
" elif 'Endpoint' in domain_info:\n",
51+
" domain_url = domain_info['Endpoint']\n",
52+
" else:\n",
53+
" print(f\"No endpoint found for domain '{domain_name}'\")\n",
54+
" return None, None\n",
55+
"\n",
4356
" return f'https://{domain_url}', domain_arn\n",
4457
"\n",
4558
" except opensearch_client.exceptions.ResourceNotFoundException:\n",

docs/tutorials/aws/DeepSeek_demo_notebook_for_RAG.ipynb

Lines changed: 15 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,8 +65,22 @@
6565
" try:\n",
6666
" response = self.opensearch_client.describe_elasticsearch_domain(DomainName=domain_name)\n",
6767
" domain_info = response['DomainStatus']\n",
68-
" domain_url = domain_info['Endpoint']\n",
6968
" domain_arn = domain_info['ARN']\n",
69+
"\n",
70+
" # Check if domain has VPC endpoints\n",
71+
" if 'Endpoints' in domain_info:\n",
72+
" # VPC domain case\n",
73+
" if 'vpc' in domain_info['Endpoints']:\n",
74+
" domain_url = domain_info['Endpoints']['vpc']\n",
75+
" else:\n",
76+
" domain_url = next(iter(domain_info['Endpoints'].values()))\n",
77+
" # Non-VPC domain case\n",
78+
" elif 'Endpoint' in domain_info:\n",
79+
" domain_url = domain_info['Endpoint']\n",
80+
" else:\n",
81+
" print(f\"No endpoint found for domain '{domain_name}'\")\n",
82+
" return None, None\n",
83+
"\n",
7084
" return f'https://{domain_url}', domain_arn\n",
7185
" except self.opensearch_client.exceptions.ResourceNotFoundException:\n",
7286
" print(f\"Domain '{domain_name}' not found.\")\n",

0 commit comments

Comments
 (0)