cosmosdb_sql_request plugin

S’applique à : ✅Microsoft Fabric✅Azure Data Explorer✅Azure Monitor✅Microsoft Sentinel

Le cosmosdb_sql_request plug-in envoie une requête SQL à un point de terminaison réseau SQL Azure Cosmos DB et retourne les résultats de la requête. Ce plug-in est principalement conçu pour interroger de petits jeux de données, par exemple, enrichir des données avec des données de référence stockées dans Azure Cosmos DB. Le plug-in est appelé avec l’opérateur evaluate .

Syntaxe

evaluatecosmosdb_sql_request ( ConnectionString SqlQuery [, SqlParameters [, Options]] ) [: OutputSchema] ,

En savoir plus sur les conventions de syntaxe.

Paramètres

Options prises en charge

Le tableau suivant décrit les champs pris en charge du paramètre Options .

Authentification et autorisation

Pour autoriser un point de terminaison réseau SQL Azure Cosmos DB, vous devez spécifier les informations d’autorisation. Le tableau suivant fournit les méthodes d’authentification prises en charge et la description de l’utilisation de cette méthode.

Définir la stratégie de légende

Le plug-in effectue des légendes à l’instance Azure Cosmos DB. Assurez-vous que la stratégie de légende du cluster active les appels de type cosmosdb vers cosmosDbUri cible.

L’exemple suivant montre comment définir la stratégie de légende pour Azure Cosmos DB. Il est recommandé de le restreindre à des points de terminaison spécifiques (my_endpoint1, my_endpoint2).

[
  {
    "CalloutType": "CosmosDB",
    "CalloutUriRegex": "my_endpoint1\\.documents\\.azure\\.com",
    "CanCall": true
  },
  {
    "CalloutType": "CosmosDB",
    "CalloutUriRegex": "my_endpoint2\\.documents\\.azure\\.com",
    "CanCall": true
  }
]

L’exemple suivant montre une commande de stratégie de modification de légende pour cosmosdb CalloutType

.alter cluster policy callout @'[{"CalloutType": "cosmosdb", "CalloutUriRegex": "\\.documents\\.azure\\.com", "CanCall": true}]'

Exemples

Les exemples suivants utilisent du texte d’espace réservé, entre crochets.

Interroger Azure Cosmos DB avec un schéma de sortie défini par la requête

L’exemple suivant utilise le plug-in cosmosdb_sql_request pour envoyer une requête SQL tout en sélectionnant uniquement des colonnes spécifiques. Cette requête utilise des définitions de schéma explicites qui permettent différentes optimisations avant l’exécution de la requête réelle sur Cosmos DB.

evaluate cosmosdb_sql_request(
  'AccountEndpoint=https://cosmosdbacc.documents.azure.com/;Database=<MyDatabase>;Collection=<MyCollection>;AccountKey='h'<AccountKey>',
  'SELECT c.Id, c.Name from c') : (Id:long, Name:string) 

Interroger Azure Cosmos DB

L’exemple suivant utilise le plug-in cosmosdb_sql_request pour envoyer une requête SQL pour extraire des données à partir d’Azure Cosmos DB à l’aide de son azure Cosmos DB pour NoSQL.

evaluate cosmosdb_sql_request(
  'AccountEndpoint=https://cosmosdbacc.documents.azure.com/;Database=<MyDatabase>;Collection=<MyCollection>;AccountKey='h'<AccountKey>',
  'SELECT * from c') // OutputSchema is unknown, so it is not specified. This may harm the performance of the query.

Interroger Azure Cosmos DB avec des paramètres

L’exemple suivant utilise des paramètres de requête SQL et interroge les données d’une autre région. Pour plus d’informations, consultez preferredLocations.

evaluate cosmosdb_sql_request(
   'AccountEndpoint=https://cosmosdbacc.documents.azure.com/;Database=<MyDatabase>;Collection=<MyCollection>;AccountKey='h'<AccountKey>',
    "SELECT c.id, c.lastName, @param0 as Column0 FROM c WHERE c.dob >= '1970-01-01T00:00:00Z'",
    dynamic({'@param0': datetime(2019-04-16 16:47:26.7423305)}),
    dynamic({'preferredLocations': ['East US']})) : (Id:long, Name:string, Column0: datetime) 
| where lastName == 'Smith'

Interroger Azure Cosmos DB et joindre des données avec une table de base de données

L’exemple suivant joint les données de partenaire à partir d’une base de données Azure Cosmos DB avec des données partenaires dans une base de données à l’aide du Partner champ. Elle génère une liste de partenaires avec leurs numéros de téléphone, leur site web et leur adresse e-mail de contact triées par nom de partenaire.

evaluate cosmosdb_sql_request(
    'AccountEndpoint=https://cosmosdbacc.documents.azure.com/;Database=<MyDatabase>;Collection=<MyCollection>;AccountKey='h'<AccountKey>',
    "SELECT c.id, c.Partner, c. phoneNumber FROM c') : (Id:long, Partner:string, phoneNumber:string) 
| join kind=innerunique Partner on Partner
| project id, Partner, phoneNumber, website, Contact
| sort by Partner

Interroger Azure Cosmos DB à l’aide de l’authentification par jeton

L’exemple suivant joint les données de partenaire à partir d’une base de données Azure Cosmos DB avec des données partenaires dans une base de données à l’aide du Partner champ. Elle génère une liste de partenaires avec leurs numéros de téléphone, leur site web et leur adresse e-mail de contact triées par nom de partenaire.

evaluate cosmosdb_sql_request(
    'AccountEndpoint=https://cosmosdbacc.documents.azure.com/;Database=<MyDatabase>;Collection=<MyCollection>;',
    "SELECT c.Id, c.Name, c.City FROM c",
    dynamic(null),
    dynamic({'token': h'abc123...'})
) : (Id:long, Name:string, City:string)

Interroger Azure Cosmos DB à l’aide de l’ID de ressource Azure Resource Manager pour l’authentification

L’exemple suivant utilise l’ID de ressource Azure Resource Manager pour l’authentification et le jeton Microsoft Entra du principal demandeur, car un jeton n’est pas spécifié. Il envoie une requête SQL tout en sélectionnant uniquement des colonnes spécifiques et spécifie des définitions de schéma explicites.

evaluate cosmosdb_sql_request(
    'AccountEndpoint=https://cosmosdbacc.documents.azure.com/;Database=<MyDatabase>;Collection=<MyCollection>;',
    "SELECT c.Id, c.Name, c.City FROM c",
    dynamic({'armResourceId': '/subscriptions/<SubscriptionId>/resourceGroups/<ResourceGroup>/providers/Microsoft.DocumentDb/databaseAccounts/<DatabaseAccount>'})
) : (Id:long, Name:string, City:string)