Megosztás a következőn keresztül:

remote_query táblaértékű függvény

A következőkre vonatkozik:jelölje be az igennel jelölt jelölőnégyzetet Databricks SQL jelölje be az igennel jelölt jelölőnégyzetet Databricks Runtime

Fontos

Ez a funkció nyilvános előzetes verzióban van.

A távoli adatbázismotoron végrehajtott lekérdezés táblázatos eredményét adja vissza.

remote_query adatokat hív le távoli rendszerekből egy kapcsolat hitelesítő adataival. A függvény az összekötők beállításainak egy halmazát fogadja el, beleértve a lekérdezést is.

Ehhez a függvényhez elnevezett paraméterhívás szükséges.

Szemantika

remote_query(connectionName [, connectorOptionKey => connectorOptionValue ] [...])

Arguments

  • connectionName

    Kötelező STRING konstans, amely a Unity Catalog kapcsolat nevére hivatkozik. Ha a kapcsolat neve nem található, a Databricks CONNECTION_NOT_FOUND-t jelez.

    A következő kapcsolatok elérhetők:

    • BigQuery
    • MySQL
    • Oracle
    • PostgreSQL
    • Redshift
    • Snowflake
    • SQL Server
    • Teradata

    Ha a kapcsolat nem támogatott CONNECTION_TYPE_NOT_SUPPORTED_FOR_REMOTE_QUERY_FUNCTION , akkor kivétel keletkezik.

  • connectorOptionKey

    Az összekötő opció kulcsa, amely esetérzékeny azonosító. Minden kapcsolattípus rendelkezik megfelelő kötelező beállításokkal (az SQL-adatbázisokhoz való csatlakozáshoz a query vagy table beállítás szükséges, míg a NoSQL-adatbázisokhoz a collection beállítás), valamint további választható konfigurációs beállításokkal (például a MySQL, PostgreSQL, SQLServer és más JDBC-szerű kapcsolatok támogatják a fetchSize, mely konfigurálja a beolvasandó kötegek méretét). Ha a kulcs nem támogatott PARAMETER_NOT_SUPPORTED_FOR_REMOTE_QUERY_FUNCTION , akkor a program előhoz egy kulcsot.

  • connectorOptionValue

    Állandó kifejezés , amely az összekötő beállításértékét jelöli.

Visszatérítések

Visszaad egy táblát. A kimeneti séma a lekérdezéstől vagy a távoli rendszeren vizsgált tábláktól függ.

Jegyzetek

Ez a függvény nem használható streamelési lekérdezésekben (UNSUPPORTED_STREAMING_TABLE_VALUED_FUNCTION).

Példák

-- Simple example with MySQL connection
> SELECT a, b FROM remote_query('mysql_connection', query => 'SELECT * FROM mysql_database.mysql_table WHERE sin(b) = 0.5');
  a        b
  angle_1  30

-- Simple example with MongoDB (NoSQL) connection
> SELECT a, b FROM remote_query('mongo_connection', collection => 'collection1', pipeline => '[{''$match'': {''b'': 30}}]');
  a        b
  angle_1  30

-- Connection name does not exist
> SELECT * FROM remote_query('non_existent_uc_connection', query => '');
  Error: CONNECTION_NOT_FOUND

-- Connection type is not supported
> SELECT * FROM remote_query('google_drive_connection', query => '');
  Error: CONNECTION_TYPE_NOT_SUPPORTED_FOR_REMOTE_QUERY_FUNCTION
  • Last updated on