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_用戶指南_日誌服務-阿裏雲