tencent cloud

文档反馈

Schema 管理

最后更新时间:2024-01-09 14:54:11

    操作场景

    CKafka 连接器支持 Schema 管理功能,您可以将创建好的 Schema 绑定到具体的数据流入任务上,将会按该 Schema 对流入的数据进行格式校验。

    操作步骤

    创建 Schema

    接下来以订阅 MySQL 数据到 ES 为例为您介绍新建链路的操作步骤。
    1. 登录 CKafka 控制台
    2. 在左侧导航栏选择连接器 > Schema 管理,选择好地域后,单击新建 Schema,填写 Schema 信息。
    
    
    
    Schema 名称:填写 Schema 名称,只能包含字母、数字、下划线、"-"、"."。
    描述:可选,填写 Schema 描述信息。
    字段配置:添加字段,最多支持添加100条字段。
    字段名:填写字段名称。
    类型:支持 BOOLEAN,INT8,INT16,INT32,INT64,FLOAT32,FLOAT64,STRING 八种类型。
    允许为 NULL:校验上游是否存在该字段。允许为 NULL 代表:如果上游没有该字段,自动添加设置的默认值字段。
    说明:
    关于字段配置中是否为 NULL 的详细说明:
    true:
    上游字段存在且符合要求:写入。
    上游字段存在且不符合要求:不写入。
    上游字段不存在:写入默认值。
    false:
    上游字段存在且符合要求:写入。
    上游字段存在且不符合要求:不写入。
    上游字段不存在:不写入。
    描述:填写字段描述。
    3. 单击确定,完成 Schema 创建。

    删除 Schema

    在 Schema 管理列表页面,单击操作列的删除,在弹窗中二次确认后,即可删除。

    绑定任务

    Schema 创建完成后,可以绑定到具体的数据流入任务上。
    1. 在 Schema 管理列表页面,单击目标 Schema 的“ID”,进入基本信息页面。
    2. 在页面上方选择关联任务页签,单击绑定任务,勾选具体的数据流入任务,完成绑定。

    解绑任务

    1. 在 Schema 管理列表页面,单击目标 Schema 的“ID”,进入基本信息页面。
    2. 在页面上方选择关联任务页签,单击绑定任务操作栏的解绑,完成解绑。
    说明:
    解绑后,将不会按该 Schema 对数据进行格式校验。
    
    联系我们

    联系我们,为您的业务提供专属服务。

    技术支持

    如果你想寻求进一步的帮助,通过工单与我们进行联络。我们提供7x24的工单服务。

    7x24 电话支持