Skip to main content

资源管理

实时任务开发、运行所依赖的一些内容，统一称为资源。

资源用处​

  • 实时任务

    线下开发的Flink任务、PyFlink任务，通过jar包、.py文件的形式上传至平台资源中，然后在创建任务时引用该资源，即可实现任务的统一管理。

  • 任务依赖

    平台Flink任务、PyFlink任务运行可能需要依赖的一些第三方资源，也可以通过资源上传、资源引用的方式进行管理使用。

  • 自定义函数

    将实现函数逻辑的JAR包上传至平台资源中，然后引用资源完成自定义函数的创建。

  • 测试数据集

    将FlinkSQL任务调试所需要的测试数据集上传至平台资源中，在调试过程中直接引用。

资源类别​

  • 项目资源：表示该资源只能在本项目内被查询、使用。
  • 全局资源：表示该资源可以在本租户所有项目内被查询、使用。

资源管理​

上传资源​

将平台需要使用的资源文件上传至指定目录下。

note
  1. 虽然资源类型不限制格式，但如果需要在平台被正确引用，在资源类型下拉框请选择正确的类型。目前可以指定的类型有JAR、PYRHON、CSV
  2. 超过100M的文件，无法上传
  3. 存储路径：文件存储至平台部署的SFTP中。上传资源默认存储在控制台的sftp路径后自动创建的stream文件夹中。您也可以手动输入指定存储路径

image-20230116170029687

资源管理​

  • 资源查看：点击资源名称，查看资源的详细信息（如名称、存储路径、修改时间等）和版本记录。

    image-20220707141657926

  • 资源删除：右键资源名称，支持删除资源

    note

    删除资源后，引用该资源的函数或代码在运行时会报错，故请慎重操作。如有改动，尽量通知到依赖该资源的其他对象的负责人

  • 资源引用情况：查看资源被函数、任务引用的关系

    image-20220707141657926 image-20220707141657926