跳到主要内容

查询元数据

在本教程中,我们将引导你完成以下步骤:将示例 Parquet 文件上传到内部 Stage,推断列定义,并创建一个包含文件级别元数据字段的表。当你想要跟踪每一行的来源或在数据集中包含文件名和行号等元数据时,这将非常有用。

开始之前

在开始之前,请确保你已准备好以下先决条件:

  • 下载示例数据集 并将其保存到你的本地文件夹。
  • BendSQL 已安装在你的本地机器上。有关如何使用各种包管理器安装 BendSQL 的说明,请参阅 安装 BendSQL

步骤 1:创建一个内部 Stage

CREATE STAGE my_internal_stage;

步骤 2:使用 BendSQL 上传示例文件

假设你的示例数据集位于 /Users/eric/Documents/iris.parquet,请在 BendSQL 中运行以下命令将其上传到 Stage:

PUT fs:///Users/eric/Documents/iris.parquet @my_internal_stage;
┌───────────────────────────────────────────────────────┐
filestatus │ size │
├────────────────────────────────────┼─────────┼────────┤
/Users/eric/Documents/iris.parquet │ SUCCESS │ 6164
└───────────────────────────────────────────────────────┘

步骤 3:从暂存文件中查询列定义

SELECT * FROM INFER_SCHEMA(location => '@my_internal_stage/iris.parquet');
┌──────────────────────────────────────────────┐
│ column_name │ type │ nullable │ order_id │
├──────────────┼─────────┼──────────┼──────────┤
│ id │ BIGINTtrue0
│ sepal_length │ DOUBLEtrue1
│ sepal_width │ DOUBLEtrue2
│ petal_length │ DOUBLEtrue3
│ petal_width │ DOUBLEtrue4
│ species │ VARCHARtrue5
└──────────────────────────────────────────────┘

步骤 4:使用元数据字段预览文件内容

你可以使用 metadata$filenamemetadata$file_row_number 等元数据字段来检查文件级别的信息:

SELECT
metadata$filename,
metadata$file_row_number,
*
FROM @my_internal_stage/iris.parquet
LIMIT 5;
┌──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┐
│ metadata$filename │ metadata$file_row_number │ id │ sepal_length │ sepal_width │ petal_length │ petal_width │ species │ metadata$filename │ metadata$file_row_number │
├───────────────────┼──────────────────────────┼─────────────────┼───────────────────┼───────────────────┼───────────────────┼───────────────────┼──────────────────┼───────────────────┼──────────────────────────┤
│ iris.parquet │ 015.13.51.40.2 │ setosa │ iris.parquet │ 0
│ iris.parquet │ 124.931.40.2 │ setosa │ iris.parquet │ 1
│ iris.parquet │ 234.73.21.30.2 │ setosa │ iris.parquet │ 2
│ iris.parquet │ 344.63.11.50.2 │ setosa │ iris.parquet │ 3
│ iris.parquet │ 4553.61.40.2 │ setosa │ iris.parquet │ 4
└──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┘

步骤 5:创建一个包含元数据字段的表

让我们创建一个表,其中包含推断的列以及文件名和行号等元数据字段:

CREATE TABLE iris_with_meta AS
SELECT
metadata$filename AS iris_file,
metadata$file_row_number AS row_index,
sepal_length,
sepal_width,
petal_length,
petal_width,
species
FROM @my_internal_stage/iris.parquet;

步骤 6:查询带有元数据的数据

SELECT * FROM iris_with_meta LIMIT 5;
┌────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┐
│ iris_file │ row_index │ sepal_length │ sepal_width │ petal_length │ petal_width │ species │
├──────────────────┼──────────────────┼───────────────────┼───────────────────┼───────────────────┼───────────────────┼──────────────────┤
│ iris.parquet │ 05.13.51.40.2 │ setosa │
│ iris.parquet │ 14.931.40.2 │ setosa │
│ iris.parquet │ 24.73.21.30.2 │ setosa │
│ iris.parquet │ 34.63.11.50.2 │ setosa │
│ iris.parquet │ 453.61.40.2 │ setosa │
└────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┘