全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 钉钉智能硬件
日志服务

通过 StreamCompute 消费

更新时间:2017-06-12 13:30:35

StreamCompute 在创建Loghub类型数据源后,可以直接消费Loghub中数据,配置如下:

  1. CREATE STREAM TABLE source_test_galaxy ( $schema ) WITH ( type='loghub', endpoint=$endpoint, accessId=$loghub_access_id, accessKey=$loghub_access_key, projectName=$project, logstore=$logstore );

参数列表:

参数 参数说明
$schema 将日志中哪些Key映射成StreamCompute表中的Column,如:name STRING, age STRING, id STRING
$endpoint 数据访问接入点,各Region接入点
$loghub_access_id 有读权限账号(或子账号)对应AccessId。
$loghub_access_key 有读权限账号(或子账号)对应AccessKey。
$project 数据所在Project。
$logstore 数据所在Logstore。

示例:

  1. CREATE STREAM TABLE source_test_galaxy ( name STRING, age STRING, id STRING ) WITH ( type='loghub', endpoint='http://cn-hangzhou-intranet.log.aliyuncs.com', accessId='mock_access_id', accessKey='mock_access_key', projectName='ali-cloud-streamtest', logstore='stream-test' );
本文导读目录