Samples for search #11338
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -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) | ||
|
There was a problem hiding this comment. Just for what looks like a more complete (enough) example, maybe add a |
||
| ] | ||
| index = Index(name=index_name, fields=fields) | ||
| ind_client = service_client.get_indexes_client() | ||
|
There was a problem hiding this comment. Eventually, the method name should comply with the guidelines, i.e. that the model name is part of not only the client name ({Model}Client), but the method is get_{Model}Client (granted, in snake case idiomatic of python). Might consider doing before the UX study so, if people say "that's too long", we can take that back to archboard. |
||
| async with ind_client: | ||
| index = await ind_client.create_index(index) | ||
|
There was a problem hiding this comment. The methods - now on sub-clients - should not repeat the model. I.e. just |
||
|
|
||
| # [START create_indexer_async] | ||
heaths marked this conversation as resolved.
Show resolved
Hide resolved
|
||
| # create a datasource | ||
| ds_client = service_client.get_datasources_client() | ||
| credentials = DataSourceCredentials(connection_string=connection_string) | ||
|
There was a problem hiding this comment. This connection string should just go onto the |
||
| container = DataContainer(name='searchcontainer') | ||
|
There was a problem hiding this comment.
|
||
| ds = DataSource(name="async-indexer-datasource", type="azureblob", credentials=credentials, container=container) | ||
|
There was a problem hiding this comment.
|
||
| 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() | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,187 @@ | ||
| { | ||
|
There was a problem hiding this comment. Did you already have samples using medical data? Seems most others have been using the hotels sample. As long as you're consistent, though. If this is the first of new samples, you might consider a consistent model (i.e. hotels) for similarity across languages' samples. There was a problem hiding this comment. Having skimmed the contents as well, I'm a little worried the topic of conversation might be triggering to people who have been impacted by this tragedy. Hotels seem pretty safe. There was a problem hiding this comment. changed it to use hotel data - agree with patient data being sensitive - yes i already had the data for a different project i've been working on |
||
| "agebracket": "20", | ||
| "backupnotes": "Student from Wuhan", | ||
| "contractedfromwhichpatientsuspected": "", | ||
| "currentstatus": "Recovered", | ||
| "dateannounced": "30/01/2020", | ||
| "detectedcity": "Thrissur", | ||
| "detecteddistrict": "Thrissur", | ||
| "detectedstate": "Kerala", | ||
| "estimatedonsetdate": "", | ||
| "gender": "F", | ||
| "nationality": "India", | ||
| "notes": "Travelled from Wuhan", | ||
| "patientnumber": "1", | ||
| "statecode": "KL", | ||
| "typeoftransmission": "Imported" | ||
| } | ||
| { | ||
| "agebracket": "", | ||
| "backupnotes": "Student from Wuhan", | ||
| "contractedfromwhichpatientsuspected": "", | ||
| "currentstatus": "Recovered", | ||
| "dateannounced": "02/02/2020", | ||
| "detectedcity": "Alappuzha", | ||
| "detecteddistrict": "Alappuzha", | ||
| "detectedstate": "Kerala", | ||
| "estimatedonsetdate": "", | ||
| "gender": "", | ||
| "nationality": "India", | ||
| "notes": "Travelled from Wuhan", | ||
| "patientnumber": "2", | ||
| "statecode": "KL", | ||
| "typeoftransmission": "Imported" | ||
| } | ||
| { | ||
| "agebracket": "", | ||
| "backupnotes": "Student from Wuhan", | ||
| "contractedfromwhichpatientsuspected": "", | ||
| "currentstatus": "Recovered", | ||
| "dateannounced": "03/02/2020", | ||
| "detectedcity": "Kasaragod", | ||
| "detecteddistrict": "Kasaragod", | ||
| "detectedstate": "Kerala", | ||
| "estimatedonsetdate": "", | ||
| "gender": "", | ||
| "nationality": "India", | ||
| "notes": "Travelled from Wuhan", | ||
| "patientnumber": "3", | ||
| "statecode": "KL", | ||
| "typeoftransmission": "Imported" | ||
| } | ||
| { | ||
| "agebracket": "45", | ||
| "backupnotes": "Travel history to Italy and Austria", | ||
| "contractedfromwhichpatientsuspected": "", | ||
| "currentstatus": "Recovered", | ||
| "dateannounced": "02/03/2020", | ||
| "detectedcity": "East Delhi (Mayur Vihar)", | ||
| "detecteddistrict": "East Delhi", | ||
| "detectedstate": "Delhi", | ||
| "estimatedonsetdate": "", | ||
| "gender": "M", | ||
| "nationality": "India", | ||
| "notes": "Travelled from Austria, Italy", | ||
| "patientnumber": "4", | ||
| "statecode": "DL", | ||
| "typeoftransmission": "Imported" | ||
| } | ||
| { | ||
| "agebracket": "20", | ||
| "backupnotes": "Student from Italy", | ||
| "contractedfromwhichpatientsuspected": "", | ||
| "currentstatus": "Recovered", | ||
| "dateannounced": "30/01/2020", | ||
| "detectedcity": "Thrissur", | ||
| "detecteddistrict": "Thrissur", | ||
| "detectedstate": "Kerala", | ||
| "estimatedonsetdate": "", | ||
| "gender": "F", | ||
| "nationality": "India", | ||
| "notes": "Travelled from USA", | ||
| "patientnumber": "5", | ||
| "statecode": "KL", | ||
| "typeoftransmission": "Imported" | ||
| } | ||
| { | ||
| "agebracket": "", | ||
| "backupnotes": "", | ||
| "contractedfromwhichpatientsuspected": "", | ||
| "currentstatus": "Recovered", | ||
| "dateannounced": "02/02/2020", | ||
| "detectedcity": "Mumbail", | ||
| "detecteddistrict": "Mumbail", | ||
| "detectedstate": "Maharashtra", | ||
| "estimatedonsetdate": "", | ||
| "gender": "", | ||
| "nationality": "India", | ||
| "notes": "Family of infected", | ||
| "patientnumber": "6", | ||
| "statecode": "MH", | ||
| "typeoftransmission": "Imported" | ||
| } | ||
| { | ||
| "agebracket": "", | ||
| "backupnotes": "", | ||
| "contractedfromwhichpatientsuspected": "", | ||
| "currentstatus": "Death", | ||
| "dateannounced": "03/02/2020", | ||
| "detectedcity": "Kasaragod", | ||
| "detecteddistrict": "Kasaragod", | ||
| "detectedstate": "Kerala", | ||
| "estimatedonsetdate": "", | ||
| "gender": "", | ||
| "nationality": "India", | ||
| "notes": "Travelled from Wuhan", | ||
| "patientnumber": "7", | ||
| "statecode": "KL", | ||
| "typeoftransmission": "Imported" | ||
| } | ||
| { | ||
| "agebracket": "23", | ||
| "backupnotes": "Travel history to Italy and Austria", | ||
| "contractedfromwhichpatientsuspected": "", | ||
| "currentstatus": "Recovered", | ||
| "dateannounced": "02/03/2020", | ||
| "detectedcity": "East Delhi (Mayur Vihar)", | ||
| "detecteddistrict": "East Delhi", | ||
| "detectedstate": "Delhi", | ||
| "estimatedonsetdate": "", | ||
| "gender": "M", | ||
| "nationality": "India", | ||
| "notes": "Travelled from Austria, Italy", | ||
| "patientnumber": "8", | ||
| "statecode": "DL", | ||
| "typeoftransmission": "Imported" | ||
| } | ||
| { | ||
| "agebracket": "20", | ||
| "backupnotes": "Student from Wuhan", | ||
| "contractedfromwhichpatientsuspected": "", | ||
| "currentstatus": "Recovered", | ||
| "dateannounced": "30/01/2020", | ||
| "detectedcity": "Thrissur", | ||
| "detecteddistrict": "Thrissur", | ||
| "detectedstate": "Kerala", | ||
| "estimatedonsetdate": "", | ||
| "gender": "F", | ||
| "nationality": "India", | ||
| "notes": "Travelled from Wuhan", | ||
| "patientnumber": "9", | ||
| "statecode": "KL", | ||
| "typeoftransmission": "Imported" | ||
| } | ||
| { | ||
| "agebracket": "", | ||
| "backupnotes": "Student from Wuhan", | ||
| "contractedfromwhichpatientsuspected": "", | ||
| "currentstatus": "Infected", | ||
| "dateannounced": "02/02/2020", | ||
| "detectedcity": "Alappuzha", | ||
| "detecteddistrict": "Alappuzha", | ||
| "detectedstate": "Kerala", | ||
| "estimatedonsetdate": "", | ||
| "gender": "", | ||
| "nationality": "India", | ||
| "notes": "Travelled from Wuhan", | ||
| "patientnumber": "10", | ||
| "statecode": "KL", | ||
| "typeoftransmission": "Imported" | ||
| } | ||
| { | ||
| "agebracket": "", | ||
| "backupnotes": "Student from Wuhan", | ||
| "contractedfromwhichpatientsuspected": "", | ||
| "currentstatus": "Recovered", | ||
| "dateannounced": "03/02/2020", | ||
| "detectedcity": "Kasaragod", | ||
| "detecteddistrict": "Kasaragod", | ||
| "detectedstate": "Kerala", | ||
| "estimatedonsetdate": "", | ||
| "gender": "", | ||
| "nationality": "India", | ||
| "notes": "Travelled from Wuhan", | ||
| "patientnumber": "11", | ||
| "statecode": "KL", | ||
| "typeoftransmission": "Imported" | ||
| } | ||
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
messed up aio in indexer :(