ApplyMapping 类 - Amazon Glue
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

ApplyMapping 类

DynamicFrame 中应用映射。

Methods

__call__(frame, mappings, transformation_ctx = "", info = "", stageThreshold = 0, totalThreshold = 0)

将声明映射到指定的 DynamicFrame

  • frame – 要在其中应用映射的 DynamicFrame (必需)。

  • mappings – 映射元组列表,每个元组包括:(源列,源类型,目标列,目标类型)。必填项。

    如果源列的名称中含有点“.”、方括号“[]”或圆括号“()”,则除非在外面加上反引号“``”,否则映射将不起作用。例如,要将 this.old.name(字符串)映射到 thisNewName(字符串),将 [id](长整型)映射到 id(长整型),可以使用以下元组:

    ("`this.old.name`", "string", "thisNewName", "string"), ("`[id]`", "long", "id", "long")
  • transformation_ctx – 用于标识状态信息的唯一字符串 (可选)。

  • info – 与转换中的错误关联的字符串 (可选)。

  • stageThreshold – 在转换出错之前可能在其中发生的最大错误数 (可选;默认值为零)。

  • totalThreshold – 在处理出错之前可能全面发生的最大错误数 (可选;默认值为零)。

仅返回“映射”元组中指定的 DynamicFrame 的字段。

apply(cls, *args, **kwargs)

继承自 GlueTransform apply

name(cls)

继承自 GlueTransform 名称

describeArgs(cls)

继承自 GlueTransform describeArgs

describeReturn(cls)

继承自 GlueTransform describeReturn

describeTransform(cls)

继承自 GlueTransform describeTransform

describeErrors(cls)

继承自 GlueTransform describeErrors

describe(cls)

继承自 GlueTransform 描述

ApplyMapping 示例

此示例为使用以下架构的 DynamicFrame 调用 ApplyMapping:

order_schema = StructType([ StructField("order_id", StringType()), StructField("customer_id", StringType()), StructField("essential_item", StringType()), StructField("timestamp", StringType()), StructField("zipcode", StringType()) ])

此示例将一些 String 列更改为 Long 格式以节省存储空间。它还将列 zipcode 的名称缩短为 zip

dyf_applyMapping = ApplyMapping.apply( frame = dyf_orders, mappings = [ ("order_id","String","order_id","Long"), ("customer_id","String","customer_id","Long"), ("essential_item","String","essential_item","String"), ("timestamp","String", "timestamp","Long"), ("zipcode","String","zip","Long") ])