196      阿里云

通过StreamCompute消费__loghub-消费_用户指南_日志服务-阿里云

StreamCompute在创建LogHub类型数据源后，可以直接消费LogHub中数据，步骤如下：

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

例子:

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

最后更新：2016-11-24 11:23:49

  上一篇： 通过Storm消费__loghub-消费_用户指南_日志服务-阿里云

  下一篇： 投递日志到OSS__logshipper_用户指南_日志服务-阿里云