Uso de consultas de acceso directo federadas

En Athena, puede ejecutar consultas en orígenes de datos federados utilizando el lenguaje de consulta del propio origen de datos y enviar la consulta completa al origen de datos para su ejecución. Estas consultas se denominan consultas de acceso directo. Para ejecutar consultas de acceso directo, utilice una función de tabla en la consulta de Athena. Incluya la consulta de acceso directo que se ejecutará en el origen de datos en uno de los argumentos de la función de tabla. Las consultas de acceso directo devuelven una tabla que puede analizar con Athena SQL.

Conectores admitidos

Los siguientes conectores de orígenes de datos de Athena admiten consultas de acceso directo.

Consideraciones y limitaciones

Cuando utilice las consultas de acceso directo en Athena, tenga en cuenta los siguientes puntos:

Sintaxis

La sintaxis general del acceso directo de las consultas de Athena es la siguiente.

SELECT * FROM TABLE(catalog.system.function_name(arg1 => 'arg1Value'[, arg2 => 'arg2Value', ...]))

Tenga en cuenta lo siguiente:

En la mayoría de los orígenes de datos, el primer y único argumento es query seguido del operador de flecha => y la cadena de consulta.

SELECT * FROM TABLE(catalog.system.query(query => 'query string'))

Para simplificar, puede omitir el argumento con nombre opcional query y el operador de flecha =>.

SELECT * FROM TABLE(catalog.system.query('query string'))

Puede simplificar aún más la consulta al eliminar el nombre del catalog si la consulta se ejecuta dentro del contexto del catálogo objetivo.

SELECT * FROM TABLE(system.query('query string'))

Si el origen de datos requiere más que la cadena de consulta, utilice los argumentos con nombre en el orden esperado por el origen de datos. Por ejemplo, la expresión arg1 => 'arg1Value' contiene el primer argumento y su valor. El nombre arg1 es específico del origen de datos y puede variar de un conector a otro.

SELECT * FROM TABLE(
        system.query(
            arg1 => 'arg1Value',
            arg2 => 'arg2Value',
            arg3 => 'arg3Value'
        ));

Lo anterior también se puede simplificar al eliminar los nombres de los argumentos. Sin embargo, debe seguir el orden de la firma del método. Consulte la documentación de cada conector para obtener más información sobre la firma de la función.

SELECT * FROM TABLE(catalog.system.query('arg1Value', 'arg2Value', 'arg3Value'))

Puede ejecutar varias consultas de acceso directo a través de diferentes conectores de Athena mediante la ruta de resolución completa de la función, como se muestra en el siguiente ejemplo.

SELECT c_customer_sk 
    FROM TABLE (postgresql.system.query('select * from customer limit 10'))
UNION
SELECT c_customer_sk 
    FROM TABLE(dynamodb.system.query('select * from customer')) LIMIT 10

Puede utilizar las consultas de acceso directo como parte de una vista federada. Se aplican las mismas limitaciones. Para más información, consulte Consulta de vistas federadas.

CREATE VIEW catalog.database.ViewName AS
    SELECT * FROM TABLE (
        catalog.system.query('query')
    )

Para obtener información sobre la sintaxis exacta a utilizar con un conector particular, consulte la documentación del conector correspondiente.

Uso de comillas

Los valores de los argumentos, incluida la cadena de consulta que pase, deben escribirse entre comillas simples, como en el siguiente ejemplo.

SELECT * FROM TABLE(system.query(query => 'SELECT * FROM testdb.persons LIMIT 10'))

Cuando la cadena de consulta está entre comillas dobles, la consulta falla. Se produce un error en la siguiente consulta y aparece el mensaje de error COLUMNA_NO_ENCONTRADA: línea 1:43: Columna 'seleccionar * de testdb.persons límite 10' no se puede resolver.

SELECT * FROM TABLE(system.query(query => "SELECT * FROM testdb.persons LIMIT 10"))

Para evitar una comilla simple, añada una comilla simple al original (por ejemplo, terry's_group a terry''s_group).

Ejemplos

El siguiente ejemplo de consulta envía una consulta a un origen de datos. La consulta selecciona todas las columnas de la tabla customer y limita los resultados a 10.

SELECT * FROM TABLE(
        catalog.system.query(
            query => 'SELECT * FROM customer LIMIT 10;'
        ))

La siguiente instrucción ejecuta la misma consulta, pero elimina el argumento con nombre opcional query y el operador de flecha =>.

SELECT * FROM TABLE(
        catalog.system.query(
            'SELECT * FROM customer LIMIT 10;'
        ))

Además, se puede agrupar en una vista federada para optimizar su reutilización. Cuando se utiliza con una vista, debe emplear la ruta de resolución completa de la función.

CREATE VIEW AwsDataCatalog.default.example_view AS
    SELECT * FROM TABLE (
        catalog.system.query('SELECT * FROM customer LIMIT 10;')
    )

Exclusión del acceso directo de las consultas

Para desactivar las consultas de acceso directo, agregue una variable de entorno de Lambda denominada enable_query_passthrough y configúrela en false.