Samples for search

sdk/search/azure-search-documents/azure/search/documents/__init__.py

@@ -73,6 +73,8 @@
     ImageAnalysisSkill,
     Index,
     Indexer,
+    IndexingSchedule,
+    IndexingParameters,
     InputFieldMappingEntry,
     KeepTokenFilter,
     KeyPhraseExtractionSkill,
@@ -165,6 +167,8 @@
     "ImageAnalysisSkill",
     "Index",
     "Indexer",
+    "IndexingSchedule",
+    "IndexingParameters",
     "IndexAction",
     "IndexDocumentsBatch",
     "IndexingResult",

sdk/search/azure-search-documents/azure/search/documents/_service/aio/_indexers_client.py

@@ -39,21 +39,21 @@ def __init__(self, endpoint, credential, **kwargs):
             endpoint=endpoint, sdk_moniker=SDK_MONIKER, **kwargs
         )  # type: _SearchServiceClient
 
-    def __enter__(self):
+    async def __aenter__(self):
         # type: () -> SearchIndexersClient
-        self._client.__enter__()  # pylint:disable=no-member
+        await self._client.__aenter__()  # pylint:disable=no-member
         return self
 
-    def __exit__(self, *args):
+    async def __aexit__(self, *args):
         # type: (*Any) -> None
-        return self._client.__exit__(*args)  # pylint:disable=no-member
+        return await self._client.__aexit__(*args)  # pylint:disable=no-member
 
-    def close(self):
+    async def close(self):
         # type: () -> None
-        """Close the :class:`~azure.search.documents.SearchIndexersClient` session.
+        """Close the :class:`~azure.search.documents.aio.SearchIndexersClient` session.
 
         """
-        return self._client.close()
+        return await self._client.close()
 
     @distributed_trace_async
     async def create_indexer(self, indexer, **kwargs):

sdk/search/azure-search-documents/samples/README.md

@@ -38,6 +38,10 @@ Then for common search index operations:
 
 * Analyze text: [sample_analyze_text.py](sample_analyze_text.py) ([async version](async_samples/sample_analyze_text_async.py))
 
+* CRUD operations for indexers: [sample_indexers_operations.py](sample_indexers_operations.py) ([async version](async_samples/sample_indexer_operations_async.py))
+
+* General workflow of indexer, datasource and index: [sample_indexer_datasource_skillset.py](sample_indexer_datasource_skillset.py) ([async version](async_samples/sample_indexer_datasource_skillset.py))
+
 ## Prerequisites
 * Python 2.7, or 3.5 or later is required to use this package (3.5 or later if using asyncio)
 * You must have an [Azure subscription](https://azure.microsoft.com/free/)

sdk/search/azure-search-documents/samples/async_samples/sample_indexers_operations_async.py

@@ -0,0 +1,125 @@
+# coding: utf-8
+
+# -------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+# --------------------------------------------------------------------------
+
+"""
+FILE: sample_indexer_operations_async.py
+DESCRIPTION:
+    This sample demonstrates how to get, create, update, or delete a Indexer.
+USAGE:
+    python sample_indexer_operations_async.py
+
+    Set the environment variables with your own values before running the sample:
+    1) AZURE_SEARCH_SERVICE_ENDPOINT - the endpoint of your Azure Cognitive Search service
+    2) AZURE_SEARCH_API_KEY - your search API key
+"""
+
+import asyncio
+import os
+
+service_endpoint = os.getenv("AZURE_SEARCH_SERVICE_ENDPOINT")
+key = os.getenv("AZURE_SEARCH_API_KEY")
+connection_string = os.getenv("AZURE_STORAGE_CONNECTION_STRING")
+
+from azure.core.credentials import AzureKeyCredential
+from azure.search.documents import (
+    DataSource, DataContainer, DataSourceCredentials, Index, Indexer, SimpleField, edm
+)
+from azure.search.documents.aio import SearchServiceClient
+
+service_client = SearchServiceClient(service_endpoint, AzureKeyCredential(key))
+indexers_client = service_client.get_indexers_client()
+
+async def create_indexer():
+    # create an index
+    index_name = "hotels"
+    fields = [
+        SimpleField(name="hotelId", type=edm.String, key=True),
+        SimpleField(name="baseRate", type=edm.Double)
+    ]
+    index = Index(name=index_name, fields=fields)
+    ind_client = service_client.get_indexes_client()
+    async with ind_client:
+        await ind_client.create_index(index)
+
+    # [START create_indexer_async]
+    # create a datasource
+    ds_client = service_client.get_datasources_client()
+    credentials = DataSourceCredentials(connection_string=connection_string)
+    container = DataContainer(name='searchcontainer')
+    ds = DataSource(name="async-indexer-datasource", type="azureblob", credentials=credentials, container=container)
+    async with ds_client:
+        data_source = await ds_client.create_datasource(ds)
+
+    # create an indexer
+    indexer = Indexer(name="async-sample-indexer", data_source_name="async-indexer-datasource", target_index_name="hotels")
+    async with indexers_client:
+        result = await indexers_client.create_indexer(indexer)
+    print("Create new Indexer - async-sample-indexer")
+    # [END create_indexer_async]
+
+async def list_indexers():
+    # [START list_indexer_async]
+    async with indexers_client:
+        result = await indexers_client.get_indexers()
+    names = [x.name for x in result]
+    print("Found {} Indexers in the service: {}".format(len(result), ", ".join(names)))
+    # [END list_indexer_async]
+
+async def get_indexer():
+    # [START get_indexer_async]
+    async with indexers_client:
+        result = await indexers_client.get_indexer("async-sample-indexer")
+        print("Retrived Indexer 'async-sample-indexer'")
+        return result
+    # [END get_indexer_async]
+
+async def get_indexer_status():
+    # [START get_indexer_status_async]
+    async with indexers_client:
+        result = await indexers_client.get_indexer_status("async-sample-indexer")
+        print("Retrived Indexer status for 'async-sample-indexer'")
+        return result
+    # [END get_indexer_status_async]
+
+async def run_indexer():
+    # [START run_indexer_async]
+    async with indexers_client:
+        result = await indexers_client.run_indexer("async-sample-indexer")
+        print("Ran the Indexer 'async-sample-indexer'")
+        return result
+    # [END run_indexer_async]
+
+async def reset_indexer():
+    # [START reset_indexer_async]
+    async with indexers_client:
+        result = await indexers_client.reset_indexer("async-sample-indexer")
+        print("Reset the Indexer 'async-sample-indexer'")
+        return result
+    # [END reset_indexer_async]
+
+async def delete_indexer():
+    # [START delete_indexer_async]
+    async with indexers_client:
+        indexers_client.delete_indexer("async-sample-indexer")
+    print("Indexer 'async-sample-indexer' successfully deleted")
+    # [END delete_indexer_async]
+
+async def main():
+    # await create_indexer()
+    # await list_indexers()
+    # await get_indexer()
+    # await get_indexer_status()
+    # await run_indexer()
+    # await reset_indexer()
+    # await delete_indexer()
+    # await service_client.close()
+
+if __name__ == '__main__':
+    loop = asyncio.get_event_loop()
+    loop.run_until_complete(main())
+    loop.close()