管理自定义Catalog

更新时间: 2023-05-09 10:26:09

如果Flink全托管中内置的Catalog无法满足您的业务需求,您可以使用自定义Catalog。本文为您介绍如何管理自定义Catalog,包括创建自定义Catalog类型、查看自定义Catalog和删除自定义Catalog。

注意事项

  • Catalog类型需要唯一,如果自定义Catalog的名称和后续Flink全托管中内置的名称相同,则优先使用您的自定义Catalog。

  • 删除自定义Catalog类型后,该自定义Catalog类型下注册的Catalog实例也将被删除。

进入自定义Catalog管理入口

  1. 登录实时计算控制台

  2. Flink全托管页签,单击目标工作空间操作列下的控制台

  3. 在左侧导航栏,单击元数据管理

创建自定义Catalog类型

  1. 按照进入自定义Catalog管理入口操作步骤,进入到自定义Catalog管理入口。

  2. 单击创建Catalog

  3. 自定义Catalog页签,单击创建自定义Catalog类型

  4. 创建自定义Catalog类型对话框,配置自定义Catalog信息。

    image

    方式

    说明

    上传文件

    注册JAR区域,单击上传文件,然后在上传文件右侧,单击选择文件,选择您的目标自定义Catalog文件。

    重要
    • 自定义Catalog开发详情请参见Catalogs

    • 自定义Catalog JAR文件不能大于200 MB。如果超过200 MB,建议使用外部URL方式进行。

    外部URL

    注册JAR区域,单击外部URL,填写外部URL信息。当您JAR文件超过200MB或者需要使用其他服务上存在的JAR文件时,可以使用外部URL功能获取JAR文件。

    重要
    • 如果JAR文件超过200MB,可以选择将自定义Catalog文件放在实时计算Flink全托管绑定的OSS Bucket的sql-artifacts/namespaces/{namespace}目录下,再使用该文件的HTTPS路径即可。

    • 支持使用其他服务的HTTP路径,需要该服务和实时计算Flink全托管在同一VPC下或者先打通实时计算Flink全托管和目标服务的公网网络链接后使用公网地址。详情请参见Flink全托管集群如何访问公网?

  5. 单击下一步

  6. 确认Properties信息。

    image
  7. 单击确定

创建自定义Catlog实例

在创建完自定义Catalog类型后,您就可以直接创建自定义Catalog实例了。具体的步骤如下:

  1. 进入自定义Catalog管理入口

  2. Catalog列表页面,单击创建Catalog

  3. 自定义Catalog页签,单击您刚创建好的自定义Catalog类型名称后,单击下一步

  4. 填写Catalog代码信息及参数值后,单击确定

    代码示例如下。

    CREATE CATALOG `CatalogName` 
    WITH (
    'type' = 'hologres-custom', 
    'endpoint' = 'yourEndpoint',
    'username' = 'yourUsername',
    'password' = 'yourPassord',
    'dbname' = 'yourDbname'
    );

    创建Catalog实例时,Catalog实例名称、类型和required字段为必填的,需要按照您实际情况进行修改。

    说明

    Catalog实例名称需要添加反引号(``),否则可能运行会报错。

  5. 在左侧元数据列表中,查看自定义Catalog实例是否已创建好。

查看自定义Catalog类型

  1. 进入自定义Catalog管理入口

  2. 单击创建Catalog

  3. 自定义Catalog页签,鼠标悬浮在自定义Catalog类型名称上面,查看自定义Catalog JAR包路径、Catalog类型、创建时间和创建人等信息。

删除自定义Catalog类型

  1. 进入自定义Catalog管理入口

  2. 单击创建Catalog

  3. 自定义Catalog页签,单击目标自定义Catalog名称右侧的image图标。

  4. 单击确定

阿里云首页 实时计算Flink版 相关技术圈