PolyBase-Abfrageszenarien

Artikel
07/10/2024

Gilt für: SQL Server – nur Windows Azure SQL Managed Instance

Dieser Artikel bietet Beispiele für Abfragen mit dem PolyBase-Feature von SQL Server (ab 2016). Bevor Sie diese Beispiele verwenden können, müssen Sie PolyBase installieren und konfigurieren. Weitere Informationen finden Sie im PolyBase-Leitfaden.

Wichtig

In SQL Server 2022 (16.x) werden externe PolyBase-Quellen zu Hadoop nicht unterstützt. Weitere Informationen finden Sie unter PolyBase-Connectors.

Führen Sie Transact-SQL-Anweisungen für externe Tabellen aus, oder verwenden Sie BI-Tools, um externe Tabellen abzufragen.

Auswählen aus einer externen Tabelle mit der SELECT-Anweisung

Eine einfache Abfrage, die Daten aus einer definierten externen Tabelle zurückgibt.

SELECT TOP 10 * FROM [dbo].[SensorData];

Eine einfache Abfrage, die ein Prädikat enthält.

SELECT * FROM [dbo].[SensorData]
WHERE Speed > 65;

Externe Tabellen mit dem Befehl JOIN mit lokalen Tabellen verknüpfen

SELECT InsuranceCustomers.FirstName,
   InsuranceCustomers.LastName,
   SensorData.Speed
FROM InsuranceCustomers INNER JOIN SensorData
ON InsuranceCustomers.CustomerKey = SensorData.CustomerKey
WHERE SensorData.Speed > 65
ORDER BY SensorData.Speed DESC

Daten importieren

Importieren Sie Daten aus Hadoop oder Azure Storage in SQL Server für den beständigen Speicher. Verwenden Sie SELECT INTO, um Daten, auf die eine externe Tabelle verweist, zu importieren und dauerhaft in SQL Server zu speichern. Erstellen Sie dynamisch eine relationale Tabelle, und erstellen Sie dann in einem zweiten Schritt einen Columnstore-Index am oberen Rand der Tabelle.

-- PolyBase scenario - import external data into SQL Server
-- Import data for fast drivers into SQL Server to do more in-depth analysis
-- Leverage columnstore technology
  
SELECT DISTINCT
        Insured_Customers.FirstName, Insured_Customers.LastName,
        Insured_Customers.YearlyIncome, Insured_Customers.MaritalStatus
INTO Fast_Customers from Insured_Customers INNER JOIN
(
        SELECT * FROM CarSensor_Data where Speed > 35
) AS SensorD
ON Insured_Customers.CustomerKey = SensorD.CustomerKey
ORDER BY YearlyIncome
  
CREATE CLUSTERED COLUMNSTORE INDEX CCI_FastCustomers ON Fast_Customers;

Datenexport

Exportieren von Daten aus SQL Server in Hadoop oder Azure Storage

Aktivieren Sie zunächst die Exportfunktion, indem Sie den Wert sp_configure von „allow polybase export“ auf 1 festlegen. Erstellen Sie anschließend eine externe Tabelle, die auf das Zielverzeichnis verweist. Die Anweisung CREATE EXTERNAL TABLE erstellt das Zielverzeichnis, wenn dieses noch nicht vorhanden ist. Verwenden Sie dann INSERT INTO zum Exportieren von Daten aus einer lokalen SQL Server-Tabelle in die externe Datenquelle.

Die Ergebnisse der SELECT-Anweisung werden an die angegebene Position im angegebenen Dateiformat exportiert. Die externen Dateien heißen QueryID_date_time_ID.format, wobei ID ein inkrementeller Bezeichner ist und Format das Format der exportierten Daten. Beispielsweise kann ein Dateiname „QID776_20160130_182739_0.orc“ lauten.

Hinweis

Beim Exportieren von Daten nach Hadoop oder Azure Blob Storage über PolyBase werden nur die Daten exportiert, nicht die Spaltennamen (Metadaten), wie im CREATE EXTERNAL TABLE-Befehl definiert.

-- PolyBase scenario  - export data from SQL Server to Hadoop
-- Create an external table
CREATE EXTERNAL TABLE [dbo].[FastCustomers2009] (
        [FirstName] char(25) NOT NULL,
        [LastName] char(25) NOT NULL,
        [YearlyIncome] float NULL,
        [MaritalStatus] char(1) NOT NULL
)
WITH (
        LOCATION='/old_data/2009/customerdata',
        DATA_SOURCE = HadoopHDP2,
        FILE_FORMAT = TextFileFormat,
        REJECT_TYPE = VALUE,
        REJECT_VALUE = 0
);
  
-- Export data: Move old data to Hadoop while keeping it query-able via an external table.
INSERT INTO dbo.FastCustomers2009
SELECT T.* FROM Insured_Customers T1 JOIN CarSensor_Data T2
ON (T1.CustomerKey = T2.CustomerKey)
WHERE T2.YearMeasured = 2009 and T2.Speed > 40;

Neue Katalogsichten

Die folgenden neuen Katalogsichten zeigen externe Ressourcen an.

SELECT * FROM sys.external_data_sources;
SELECT * FROM sys.external_file_formats;
SELECT * FROM sys.external_tables;

Bestimmen Sie unter Verwendung von, ob eine Tabelle eine externe Tabelle ist. is_external

SELECT name, type, is_external FROM sys.tables WHERE name='myTableName'

Nächste Schritte

Weitere Informationen zur Problembehandlung finden Sie unter PolyBase troubleshooting(PolyBase-Problembehandlung).

Freigeben über