Consultar tablas de Apache Iceberg

• Iceberg nativo de Unity (REST): no soportado.

  Solución alternativa: utilice Delta + UniForm para publicar una vista legible para Iceberg mediante el punto final REST de Iceberg de Unity Catalog.

• Catálogos de REST certificados: ADB está certificado con Snowflake Polaris y Databricks Unity Catalog (solo UniForm) para acceso de lectura a Iceberg.

• vending de credenciales de catálogo: no soportado.

  La venta basada en roles nativa de la nube, como la suposición automática de roles o las credenciales temporales emitidas por STS, no se admite. Utilice claves de acceso/secreto explícitas o tokens estáticos.)

• Credenciales de AWS ARN: no admitidas. No se aceptan ARN de rol de IAM y AssumeRole mediante ARN.

• Las tablas de iceberg particionadas no se admiten; solo se permiten tablas no particionadas.
• Actualizaciones de nivel de fila (fusión en lectura): no admitidas. Si los metadatos de Iceberg hacen referencia a archivos de supresión, las consultas fallarán.

• El esquema de una tabla externa fija se determina en la creación y debe alinearse con la versión del esquema Iceberg en los metadatos. Si se actualiza el esquema Iceberg, se debe volver a crear la tabla externa.

• Sin viaje en tiempo de consulta: la consulta por instantánea, versión o registro de hora no está soportada.
• Solo Non_catalog: las nuevas instantáneas no se seleccionan automáticamente. Para leer una instantánea específica, el destino de esa instantánea es metadata.json y volver a crear la tabla externa.

• Alineación de credenciales: se deben utilizar las mismas credenciales para AWS S3 y AWS Glue.
• Coubicación de región: los cubos S3 y el catálogo de AWS Glue deben estar en la misma región de AWS.

• Una tabla Delta creada con UniForm para que los clientes de Iceberg puedan leerla.
• Archivos de tabla en Azure ADLS Gen2 o AWS S3.
• Privilegios de Unity Catalog para acceso externo (por ejemplo, acceso a datos externos activado); otorgue EXTERNAL USE SCHEMA a su principal.
• Autenticación: OAuth2 (recomendado) o token de acceso personal (para pruebas rápidas).

USE CATALOG <your_catalog>;
USE SCHEMA  <your_schema>;

CREATE TABLE customers_iceberg (
  id   INT,
  name STRING
)
TBLPROPERTIES(
  'delta.columnMapping.mode'='name',
  'delta.enableIcebergCompatV2'='true',
  'delta.universalFormat.enabledFormats'='iceberg'
);

INSERT INTO customers_iceberg (id, name) VALUES
  (1,'Alice'), (2,'Bob'), (3,'Carol');

BEGIN
  BEGIN DBMS_CLOUD.DROP_CREDENTIAL('AZURE_BLOB_CRED'); EXCEPTION WHEN OTHERS THEN NULL; END;
  DBMS_CLOUD.CREATE_CREDENTIAL(
    credential_name => 'AZURE_BLOB_CRED',
    username        => '<storage-account-or-sas-username>',
    password        => '<storage-key-or-sas-token>'
  );
END;
/

-- Databricks service principal (client_id / client_secret)
BEGIN
  BEGIN DBMS_CLOUD.DROP_CREDENTIAL('UNITY_OAUTH'); EXCEPTION WHEN OTHERS THEN NULL; END;
  DBMS_CLOUD.CREATE_CREDENTIAL(
    credential_name => 'UNITY_OAUTH',
    username        => '<client_id>',
    password        => '<client_secret>'
  );
END;
/

BEGIN
  DBMS_CLOUD.CREATE_EXTERNAL_TABLE(
    table_name      => 'CUSTOMERS_ICEBERG',
    credential_name => 'AZURE_BLOB_CRED',
    format          => '{
      "access_protocol": {
        "protocol_type": "iceberg-rest",
        "protocol_config": {
          "iceberg_catalog_type": "unity",
          "rest_catalog_endpoint": "https://<workspace-host>/api/2.1/unity-catalog/iceberg",
          "rest_authentication": {
            "rest_auth_cred": "UNITY_OAUTH",
            "rest_auth_endpoint": "https://<workspace-host>/oidc/v1/token"
          },
          "table_path": ["<your_catalog>","<your_schema>","customers_iceberg"]
        }
      }
    }'
  );
END;
/
SELECT COUNT(*) FROM CUSTOMERS_ICEBERG;

BEGIN
  BEGIN DBMS_CLOUD.DROP_CREDENTIAL('UNITY_PAT'); EXCEPTION WHEN OTHERS THEN NULL; END;
  DBMS_CLOUD.CREATE_CREDENTIAL(
    credential_name => 'UNITY_PAT',
    username        => 'token',
    password        => '<dapiXXXXXXXXXXXXXXXXXXXXXXXX>'
  );
END;
/

BEGIN
  DBMS_CLOUD.CREATE_EXTERNAL_TABLE(
    table_name      => 'CUSTOMERS_ICEBERG',
    credential_name => 'AZURE_BLOB_CRED',
    format          => '{
      "access_protocol": {
        "protocol_type": "iceberg-rest",
        "protocol_config": {
          "iceberg_catalog_type": "unity",
          "rest_catalog_endpoint": "https://<workspace-host>/api/2.1/unity-catalog/iceberg",
          "rest_authentication": { "rest_auth_cred": "UNITY_PAT" },
          "table_path": ["<your_catalog>","<your_schema>","customers_iceberg"]
        }
      }
    }'
  );
END;
/
SELECT COUNT(*) FROM CUSTOMERS_ICEBERG;

• El catálogo y el punto final de Polaris Iceberg están disponibles para su cuenta.
• Archivos de tabla accesibles en el almacén de objetos (S3/ADLS, según corresponda).
• Auth: se recomienda OAuth2 (credenciales de cliente) u otro mecanismo de token admitido por Polaris.

BEGIN
  DBMS_CLOUD.CREATE_EXTERNAL_TABLE(
    table_name      => 'SALES_POLARIS',
    credential_name => 'S3_CRED',
    format          => '{
      "access_protocol": {
        "protocol_type": "iceberg-rest",
        "protocol_config": {
          "iceberg_catalog_type": "polaris",
          "rest_catalog_endpoint": "<https://<your-polaris-endpoint>/...>",
          "rest_authentication": {
            "rest_auth_cred": "POLARIS_OAUTH",
            "rest_auth_endpoint": "<https://<your-oauth-token-endpoint>>"
          },
          "table_path": ["<db>","<schema>","<table>"]
        }
      }
    }'
  );
END;
/

SELECT COUNT(*) FROM SALES_POLARIS;

• Catálogo de datos de pegamento con la tabla Iceberg registrada (se puede acceder a objetos S3).

  Nombre de la región de Glue (por ejemplo, us-east-1).

• Autenticación: acceda a clave/secreto para S3; pegue el acceso mediante la configuración del catálogo.

• La venta de credenciales a través de AWS ARN no está soportada. Se deben proporcionar credenciales explícitas.

BEGIN
  DBMS_CLOUD.CREATE_EXTERNAL_TABLE(
    table_name      => 'ORDERS_GLUE',
    credential_name => 'S3_CRED',
    format          => '{
      "access_protocol": {
        "protocol_type": "iceberg",
        "protocol_config": {
          "iceberg_catalog_type": "aws_glue",
          "iceberg_glue_region": "us-east-1",
          "table_path": ["<database>","<table>"]
        }
      }
    }'
  );
END;
/

SELECT COUNT(*) FROM ORDERS_GLUE;

• Puede acceder al manifiesto raíz de Iceberg de la tabla (metadata.json) en el almacén de objetos (ADLS/S3/OCI).
• Esta ruta es punto en el tiempo. Para seguir las nuevas instantáneas, vuelva a crear la tabla externa.

BEGIN
  DBMS_CLOUD.CREATE_EXTERNAL_TABLE(
    table_name      => 'CUSTOMERS_META',
    credential_name => 'STORE_CRED',
    file_uri_list   => 'https://<bucket-or-container>/<path>/metadata.json',
    format          => '{"access_protocol":{"protocol_type":"iceberg"}}'
  );
END;
/

BEGIN
  DBMS_CLOUD.CREATE_EXTERNAL_TABLE (
    table_name       => 'iceberg_parquet_time_dim3',
    credential_name  => 'OCI_CRED',
    format           => '{
      "access_protocol": {
        "protocol_type": "iceberg",
        "protocol_config": {
          "iceberg_catalog_type": "hadoop",
          "iceberg_lakehouse": "https://objectstorage.uk-cardiff-1.oraclecloud.com/n/my-tenancy/b/my-iceberg-bucket/o/iceberg",
          "iceberg_table_path": "db.icebergTablePy"
        }
      }
    }'
  );
END;
/