Observação
O acesso a essa página exige autorização. Você pode tentar entrar ou alterar diretórios.
O acesso a essa página exige autorização. Você pode tentar alterar os diretórios.
Função com valor de tabela
Aplica-se a:
Databricks SQL
Databricks Runtime
Importante
Esse recurso está em Visualização Pública.
Retorna o resultado tabular da consulta executada no mecanismo de banco de dados remoto.
remote_query busca dados de sistemas remotos usando credenciais de uma conexão.
A função aceita um conjunto de opções de conector, além da consulta.
Essa função requer invocação de parâmetro nomeada.
Sintaxe
remote_query(connectionName [, connectorOptionKey => connectorOptionValue ] [...])
Arguments
-
Um literal obrigatório
STRINGque faz referência ao Catálogo do Unity nome da conexão. Se o nome da conexão não existir, o Databricks gerará CONNECTION_NOT_FOUND.Há suporte para as seguintes conexões:
- BigQuery
- MySQL
- Oracle
- PostgreSQL
- Redshift
- Snowflake
- SQL Server
- Teradata
Se a conexão não for suportada,
CONNECTION_TYPE_NOT_SUPPORTED_FOR_REMOTE_QUERY_FUNCTIONserá acionado. connectorOptionKeyUma chave de opção do conector que é um identificador que diferencia maiúsculas de minúsculas. Cada tipo de conexão tem opções obrigatórias correspondentes (as conexões com bancos de dados SQL exigem
queryoutableopção, embora NoSQL bancos de dados exijamcollectionopção) e opções de configuração opcionais adicionais (por exemplo, MySQL, PostgreSQL, SQLServer e outras conexões semelhantes a JDBC dão suportefetchSizeque configura o tamanho dos lotes que estão sendo buscados). Se uma chave não for suportada,PARAMETER_NOT_SUPPORTED_FOR_REMOTE_QUERY_FUNCTIONserá gerado.connectorOptionValueUma expressão constante que representa o valor da opção do conector.
Devoluções
Retorna uma tabela. O esquema de saída depende da consulta ou das tabelas que estão sendo analisadas em um sistema remoto.
Condições de erro comuns
Anotações
Essa função não pode ser usada em consultas em fluxo contínuo (UNSUPPORTED_STREAMING_TABLE_VALUED_FUNCTION).
Exemplos
-- 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
Funções relacionadas
- http_request - Semelhante porque também usa credenciais de conexão do Catálogo do Unity para enviar solicitações HTTP para determinada API
- CREATE CONNECTION
- ALTER CONNECTION
- DROP CONNECTION