交互式分析(Interactive Analytics)支持从实时计算导入实时数据,进行实时查询。通过借助交互式分析(Interactive Analytics) 的blink-connector模块,以及阿里云内置大数据系统,您可以方便快速地进行实时数据的导入。

说明 :关于实时计算的开发环境配置,请参见阿里云实时计算
  1. 准备交互式分析(Interactive Analytics)表
    在交互式分析(Interactive Analytics)中输入SQL命令语句建立一张新表,目的是建立一张可以直接读取实时计算数据的映射表。示例SQL命令语句如下。
    create table test(a int, b text, c text, d float8, e int8);
  2. 准备Blink Job
    1. 登录阿里云官网,搜索实时计算,单击管理控制台,进入开发页面。
    2. 单击新建项目,输入项目信息,若您暂未购买阿里云实时计算服务,请前往官网购买。
    3. 单击右侧新建作业,并填写作业信息。
    4. 写入实时任务SQL,示例如下。
      create table randomSource (a int, b VARCHAR, c VARCHAR, d DOUBLE, e BIGINT) with (type = 'random');
      create table test (
        a int,
        b VARCHAR,
        c VARCHAR,
        d DOUBLE,
        e BIGINT,
        PRIMARY KEY (a)
      ) with (
        type = 'custom',
        tableFactoryClass = 'com.alibaba.blink.connectors.hologres.HologresTableFactory',
        `endpoint` = 'ip:port',--当前的交互式分析实例的VPC网络地址和端口
        `userName` = 'accessKeyId',   --当前用户的AccessID
        `password` = 'accessKeySecret', --当前用户的AccessKey
        `dbName` = 'exampledb',  -- 要访问的交互式分析数据库名
        `tableName` = 'test'        -- 要导入数据的交互式分析表名
      );
      insert
        into test
      select
        a,b,c,d,e
      from
        randomSource;
      undefinedundefined
      说明
      • endpoint : 交互式分析实例的VPC网络地址和端口。
      • userName :当前连接交互式分析(Interactive Analytics)的Access ID。
      • password :当前连接交互式分析(Interactive Analytics)的Access Key。
      • dbName:要访问的交互式分析(Interactive Analytics)数据库名。
      • tableName:要导入的交互式分析(Interactive Analytics)表名。

      以上信息可前往交互式分析(Interactive Analytics)管控台,选中当前实例查看。

    5. 单击左下角资源引用 > 新建资源添加blink-holo-connector Jar资源包,导入Jar资源包后。单击更多 > 引用,对该任务引用Jar资源包,若任务标签出现绿色图标,则表示该资源包引用成功。
      相关资源包请查看以下链接:
    6. 实时任务上线
      引用资源成功后,单击保存 > 语法检查 > 上线,并根据任务选择资源配置。如果语法检查不通过,确保右下角blink版本与Jar资源包版本一致。
    7. 上线发布成功之后,单击运维,启动任务成功后即可查看到当前任务运行情况。
  3. 查询表
    输入查询语句,即可查看到实时计算作业里的实时数据,示例SQL命令语句如下。
    select * from test;