在 AWS Glue 中使用 PyIceberg 创建的空 Iceberg 表缺少位置和架构

问题描述 投票:0回答:1

我想在 AWS Glue 中使用 PyIceberg 创建一个空的 Iceberg 表。 下面的代码片段创建表,但不显示 AWS Glue 中的位置和架构信息。我错过了什么?

from pyiceberg.catalog import load_catalog
from pyiceberg.schema import Schema
from pyiceberg.types import TimestampType, StringType, NestedField

schema = Schema(
    NestedField(field_id=1, name="datetime", field_type=TimestampType()),
    NestedField(field_id=2, name="job_id", field_type=StringType()),
    NestedField(field_id=3, name="result", field_type=StringType()),
    NestedField(field_id=4, name="description", field_type=StringType()),
)

if __name__ == "__main__":
    catalog = load_catalog(
        "default",
        **{
            "type": "glue",
        },
    )

    catalog.create_table(
        identifier=f"manually_created.my_test_table",
        schema=schema,
        location="s3://my_test_bucket/my_test_table",
    )

有版本

pyiceberg==0.5.1

python aws-glue apache-iceberg
1个回答
0
投票

实际上,这已在较新的 pyiceberg 版本(> 0.5.1)中修复,请参阅此 PR,如此问题中所述。

pip install pyiceberg==0.6.0rc4
并且出现位置和模式。

© www.soinside.com 2019 - 2024. All rights reserved.