postgresql_request plugin

Gilt für: ✅Microsoft Fabric✅Azure Data Explorer

Das postgresql_request Plug-In sendet eine SQL-Abfrage an einen Azure PostgreSQL Server-Netzwerkendpunkt und gibt das erste Rowset in den Ergebnissen zurück. Die Abfrage gibt möglicherweise mehrere Rowset zurück, aber nur das erste Rowset wird für den Rest der Kusto-Abfrage verfügbar gemacht.

Das Plug-In wird mit dem evaluate Operator aufgerufen.

Syntax

evaluatepostgresql_request ( ConnectionString , SqlQuery [, SqlParameters] ) [: OutputSchema]

Erfahren Sie mehr über Syntaxkonventionen.

Parameter

Authentifizierung und Autorisierung

Um einen PostgreSQL Server-Netzwerkendpunkt zu autorisieren, müssen Sie die Autorisierungsinformationen im Verbindungszeichenfolge angeben. Die unterstützte Autorisierungsmethode erfolgt über Benutzername und Kennwort.

Festlegen der Beschriftungsrichtlinie

Das Plug-In führt Legenden an die PostgreSQL-Datenbank aus. Stellen Sie sicher, dass die Beschriftungsrichtlinie des Clusters Aufrufe vom Typ postgresql an das Ziel PostgreSqlDbUri aktiviert.

Das folgende Beispiel zeigt, wie die Popuprichtlinie für PostgreSQL-Datenbanken definiert wird. Es wird empfohlen, die Popuprichtlinie auf bestimmte Endpunkte (my_endpoint1, my_endpoint2) zu beschränken.

[
  {
    "CalloutType": "postgresql",
    "CalloutUriRegex": "my_endpoint1\\.postgres\\.database\\.azure\\.com",
    "CanCall": true
  },
  {
    "CalloutType": "postgresql",
    "CalloutUriRegex": "my_endpoint2\\.postgres\\.database\\.azure\\.com",
    "CanCall": true
  }
]

Das folgende Beispiel zeigt einen .alter callout policy Befehl für postgresql CalloutType:

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

Authentifizierung per Benutzername und Kennwort

Das postgresql_request Plug-In unterstützt nur die Benutzernamen- und Kennwortauthentifizierung an den PostgreSQL-Serverendpunkt und lässt sich nicht in die Microsoft Entra-Authentifizierung integrieren.

Der Benutzername und das Kennwort werden als Teil der Verbindungszeichenfolge mit den folgenden Parametern bereitgestellt:

User ID=...; Password=...;

Verschlüsselung und Serverüberprüfung

Für die Sicherheit SslMode ist die Verbindung mit einem PostgreSQL-Servernetzwerkendpunkt bedingungslos festgelegt Required . Daher muss der Server mit einem gültigen SSL/TLS-Serverzertifikat konfiguriert werden.

Angeben des Netzwerkendpunkts

Geben Sie den PostgreSQL-Netzwerkendpunkt als Teil des Verbindungszeichenfolge an.

Syntax:

Host= FQDN [Port = Port]

Hierbei gilt:

• FQDN ist der vollqualifizierte Domänenname des Endpunkts.
• Port ist der TCP-Port des Endpunkts.

Beispiele

SQL-Abfrage zu Azure PostgreSQL DB

Im folgenden Beispiel wird eine SQL-Abfrage an eine Azure PostgreSQL-Datenbank gesendet. Es ruft alle Datensätze aus public."Table"und verarbeitet dann die Ergebnisse.

evaluate postgresql_request(
    'Host=contoso.postgres.database.azure.com; Port = 5432;'
    'Database=Fabrikam;'
    h'User Id=USERNAME;'
    h'Password=PASSWORD;',
    'select * from public."Table"') : (Id: int, Name: string)
| where Id > 0
| project Name

SQL-Abfrage an eine Azure PostgreSQL-Datenbank mit Änderungen

Im folgenden Beispiel wird eine SQL-Abfrage an eine Azure PostgreSQL-Datenbank gesendet, aus public."Table"der alle Datensätze abgerufen werden, während eine andere datetime Spalte angefügt und dann die Ergebnisse verarbeitet werden. Er gibt einen SQL-Parameter (@param0) an, der in der SQL-Abfrage verwendet werden soll.

evaluate postgresql_request(
    'Server=contoso.postgres.database.azure.com; Port = 5432;'
    'Database=Fabrikam;'
    h'User Id=USERNAME;'
    h'Password=PASSWORD;',
    'select *, @param0 as dt from public."Table"',
    dynamic({'param0': datetime(2020-01-01 16:47:26.7423305)})) : (Id: int, Name: string, dt: datetime)
| where Id > 0
| project Name

SQL-Abfrage an eine Azure PostgreSQL-Datenbank ohne abfragedefiniertes Ausgabeschema

Im folgenden Beispiel wird eine SQL-Abfrage ohne Ausgabeschema an eine Azure PostgreSQL-Datenbank gesendet. Dies wird nur empfohlen, wenn das Schema unbekannt ist, da es sich auf die Leistung der Abfrage auswirken kann.

evaluate postgresql_request(
    'Host=contoso.postgres.database.azure.com; Port = 5432;'
    'Database=Fabrikam;'
    h'User Id=USERNAME;'
    h'Password=PASSWORD;',
    'select * from public."Table"')
| where Id > 0
| project Name