Freigeben über

Ausführen von Verbundabfragen auf Amazon Redshift

  • Artikel

Wichtig

Dieses Feature befindet sich in der Public Preview.

In diesem Artikel wird beschrieben, wie Sie Lakehouse Federation einrichten, um Verbundabfragen mit Amazon Redshift-Daten auszuführen, die nicht von Azure Databricks verwaltet werden. Weitere Informationen zur Lakehouse Federation finden Sie unter Was ist Lakehouse Federation.

Um mithilfe von Lakehouse Federation eine Verbindung mit Ihrer Amazon Redshift-Datenbank herzustellen, müssen Sie Folgendes in Ihrem Azure Databricks Unity Catalog-Metastore erstellen:

  • Eine Verbindung mit Ihrer Amazon Redshift-Datenbank
  • Einen Fremdkatalog, der Ihre Amazon Redshift-Datenbank in Unity Catalog spiegelt, sodass Sie die Abfragesyntax und Datengovernancetools von Unity Catalog zum Verwalten des Azure Databricks-Benutzerzugriffs auf die Datenbank verwenden können.

Voraussetzungen

Anforderungen an den Arbeitsbereich:

  • Der Arbeitsbereich muss für Unity Catalog aktiviert sein.

Computeanforderungen:

  • Netzwerkkonnektivität zwischen Ihrem Databricks Runtime-Cluster oder SQL-Warehouse und den Zieldatenbanksystemen. Weitere Informationen finden Sie unter Netzwerkempfehlungen für Lakehouse Federation.
  • Azure Databricks-Cluster müssen Databricks Runtime 13.3 LTS oder höher und den Clusterzugriffsmodus „Freigegeben“ oder „Einzelbenutzer“ verwenden.
  • SQL-Warehouses müssen „Pro“ oder serverlos sein.

Erforderliche Berechtigungen:

  • Um eine Verbindung zu erstellen, müssen Sie Metastore-Administrator oder Benutzer mit der Berechtigung „CREATE CONNECTION“ für den Unity Catalog-Metastore sein, der an den Arbeitsbereich angefügt ist.
  • Um einen Fremdkatalog zu erstellen, müssen Sie über die Berechtigung „CREATE CATALOG“ für den Metastore verfügen und entweder der Besitzer der Verbindung sein oder über die Berechtigung „CREATE FOREIGN CATALOG“ für die Verbindung verfügen.

In jedem folgenden aufgabenbasierten Abschnitt werden zusätzliche Berechtigungsanforderungen angegeben.

Erstellen einer Verbindung

Eine Verbindung gibt einen Pfad und Anmeldeinformationen für den Zugriff auf ein externes Datenbanksystem an. Zum Erstellen einer Verbindung können Sie den Katalog-Explorer oder den SQL-Befehl „CREATE CONNECTION“ in einem Azure Databricks-Notebook oder im Databricks SQL-Abfrage-Editor verwenden.

Erforderliche Berechtigungen: Metastore-Administrator oder Benutzer mit der Berechtigung „CREATE CONNECTION“.

Katalog-Explorer

  1. Klicken Sie in Ihrem Azure Databricks-Arbeitsbereich auf Symbol „Katalog“Katalog.
  2. Erweitern Sie im linken Bereich das Menü Externe Daten, und wählen Sie Verbindungen aus.
  3. Klicken Sie auf Neue Verbindung erstellen.
  4. Geben Sie einen benutzerfreundlichen Verbindungsnamen ein.
  5. Wählen Sie als Verbindungstypdie Option Redshift aus.
  6. Geben Sie die folgenden Verbindungseigenschaften für Ihre Amazon Redshift-Instanz ein.
    • Host: Beispiel: redshift-demo.us-west-2.redshift.amazonaws.com
    • Port: Beispiel: 5439
    • Benutzer: Beispiel: redshift_user
    • Kennwort: Beispiel: password123
  7. (Optional) Klicken Sie auf Verbindung testen, um die Verbindung zu überprüfen.
  8. (Optional) Fügen Sie einen Kommentar hinzu.
  9. Klicken Sie auf Erstellen.

Sql

Führen Sie in einem Notebook oder im Databricks SQL-Abfrage-Editor den folgenden Befehl aus.

CREATE CONNECTION <connection-name> TYPE redshift
OPTIONS (
  host '<hostname>',
  port '<port>',
  user '<user>',
  password '<password>'
);

Es wird empfohlen, Aure Databricks-Geheimnisse anstelle von Klartext-Zeichenfolgen für vertrauliche Werte wie Anmeldeinformationen zu verwenden. Beispiele:

CREATE CONNECTION <connection-name> TYPE redshift
OPTIONS (
  host '<hostname>',
  port '<port>',
  user secret ('<secret-scope>','<secret-key-user>'),
  password secret ('<secret-scope>','<secret-key-password>')
)

Informationen zum Einrichten von Geheimnissen finden Sie unter Verwaltung von Geheimnissen.

Erstellen eines Fremdkatalogs

Ein Fremdkatalog spiegelt eine Datenbank in einem externen Datensystem, sodass Sie Abfragen und die Verwaltung des Zugriffs auf Daten in dieser Datenbank mithilfe von Azure Databricks und Unity Catalog steuern können. Um einen fremden Katalog zu erstellen, verwenden Sie eine Verbindung mit der bereits definierten Datenquelle.

Zum Erstellen eines fremden Katalogs können Sie den Katalog-Explorer oder den SQL-Befehl „CREATE FOREIGN CATALOG“ in einem Azure Databricks-Notebook oder im Databricks SQL-Abfrage-Editor verwenden.

Erforderliche Berechtigungen: Sie müssen über die CREATE CATALOG-Berechtigung für den Metastore verfügen und entweder Besitzer der Verbindung sein oder die Berechtigung „CREATE FOREIGN CATALOG“ für sie haben.

Katalog-Explorer

  1. Klicken Sie in Ihrem Azure Databricks-Arbeitsbereich auf Symbol „Katalog“Katalog.
  2. Klicken Sie auf die Schaltfläche Katalog erstellen.
  3. Geben Sie im Dialogfeld Neuen Katalog erstellen einen Namen für den Katalog ein, und wählen Sie als Typ die Option Fremd aus.
  4. Wählen Sie die Verbindung aus, die Zugriff auf die Datenbank bietet, die Sie als Unity Catalog-Katalog spiegeln möchten.
  5. Geben Sie den Namen der Datenbank ein, die Sie als Katalog spiegeln möchten.
  6. Klicken Sie auf Erstellen.

Sql

Führen Sie den folgenden SQL-Befehl in einem Notebook oder im Databricks SQL-Editor aus. Elemente in Klammern sind optional. Ersetzen Sie folgende Platzhalterwerte:

  • <catalog-name>: Name für den Katalog in Azure Databricks.
  • <connection-name>: Das Verbindungsobjekt, das die Datenquelle, den Pfad und die Anmeldeinformationen für den Zugriff angibt.
  • <database-name>: Name der Datenbank, die sie als Katalog in Azure Databricks spiegeln möchten.
CREATE FOREIGN CATALOG [IF NOT EXISTS] <catalog-name> USING CONNECTION <connection-name>
OPTIONS (database '<database-name>');

Unterstützte Pushdowns

Die folgenden Pushdowns werden unterstützt:

  • Filter
  • Projektionen
  • Begrenzung
  • Joins
  • Aggregate (Average, Count, Max, Min, StddevPop, StddevSamp, Sum, VarianceSamp)
  • Funktionen (Zeichenfolgenfunktionen und andere verschiedene Funktionen wie Alias, Cast, SortOrder)
  • Sortierung

Die folgenden Pushdowns werden nicht unterstützt:

  • Windows-Funktionen

Datentypzuordnungen

Wenn Sie von Amazon Redshift zu Spark lesen, werden die Datentypen wie folgt zugeordnet:

Redshift-Typ Spark-Typ
numeric DecimalType
int2, int4 IntegerType
int8, oid, xid LongType
float4 FloatType
double precision, float8, money DoubleType
bpchar, char, character varying, name, super, text, tid, varchar StringType
bytea, geometry, varbyte BinaryType
bit, bool BooleanType
date DateType
tabstime, time, time with time zone, timetz, time without time zone, timestamp with time zone, timestamp, timestamptz, timestamp without time zone* TimestampType/TimestampNTZType

* Wenn Sie aus Redshift lesen, wird Redshift Timestamp Spark TimestampType zugeordnet wenn infer_timestamp_ntz_type = false (Standard). Amazon Redshift Timestamp wird TimestampNTZType zugeordnet, wenn infer_timestamp_ntz_type = true.