1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
# pylint: disable=line-too-long,useless-suppression
# ------------------------------------
# Copyright (c) Microsoft Corporation.
# Licensed under the MIT License.
# ------------------------------------
"""
DESCRIPTION:
Given an AIProjectClient, this sample demonstrates how to use the asynchronous
`.indexes` methods to upload a file, create Indexes that reference those files,
list Indexes and delete Indexes.
USAGE:
python sample_indexes_async.py
Before running the sample:
pip install azure-ai-projects azure-identity aiohttp
Set these environment variables with your own values:
1) PROJECT_ENDPOINT - Required. The Azure AI Project endpoint, as found in the overview page of your
Azure AI Foundry project.
2) INDEX_NAME - Optional. The name of the Index to create and use in this sample.
3) INDEX_VERSION - Optional. The version of the Index to create and use in this sample.
4) AI_SEARCH_CONNECTION_NAME - Optional. The name of an existing AI Search connection to use in this sample.
5) AI_SEARCH_INDEX_NAME - Optional. The name of the AI Search index to use in this sample.
"""
import asyncio
import os
from azure.identity.aio import DefaultAzureCredential
from azure.ai.projects.aio import AIProjectClient
from azure.ai.projects.models import AzureAISearchIndex
async def main() -> None:
endpoint = os.environ["PROJECT_ENDPOINT"]
index_name = os.environ.get("INDEX_NAME", "index-test")
index_version = os.environ.get("INDEX_VERSION", "1.0")
ai_search_connection_name = os.environ.get("AI_SEARCH_CONNECTION_NAME", "my-ai-search-connection-name")
ai_search_index_name = os.environ.get("AI_SEARCH_INDEX_NAME", "my-ai-search-index-name")
async with DefaultAzureCredential() as credential:
async with AIProjectClient(endpoint=endpoint, credential=credential) as project_client:
print(
f"Create Index `{index_name}` with version `{index_version}`, referencing an existing AI Search resource:"
)
index = await project_client.indexes.create_or_update(
name=index_name,
version=index_version,
body=AzureAISearchIndex(connection_name=ai_search_connection_name, index_name=ai_search_index_name),
)
print(index)
print(f"Get Index `{index_name}` version `{index_version}`:")
index = await project_client.indexes.get(name=index_name, version=index_version)
print(index)
print("List latest versions of all Indexes:")
async for index in project_client.indexes.list():
print(index)
print(f"Listing all versions of the Index named `{index_name}`:")
async for index in project_client.indexes.list_versions(name=index_name):
print(index)
print(f"Delete Index`{index_name}` version `{index_version}`:")
await project_client.indexes.delete(name=index_name, version=index_version)
if __name__ == "__main__":
asyncio.run(main())
|
