Simple Log Service：關聯MySQL資料來源

執行查詢分析

• 使用外部儲存

  關聯外部資料源後，您可以在Log Service控制台，名為log-rds-demo的Project下，單擊任意Logstore，通過查詢分析語句* | select * from sls_join_meta_store查詢關聯的MySQL表資料。

  

• 使用JOIN關聯Log Service與MySQL表

  • 僅支援Logstore與MySQL資料庫小表（資料量小於20 MB）進行聯集查詢。

  • 查詢和分析語句中，Logstore必須寫在join關鍵字前面，ExternalStore寫在join關鍵字後面。

  • 查詢和分析語句中，必須寫ExternalStore名稱，系統自動替換成MySQL資料庫名+表名。請勿直接填寫MySQL表名。

  支援的Join文法有INNER JOIN、LEFT JOIN、RIGHT JOIN和FULL JOIN。

  [ INNER ] JOIN
  LEFT [ OUTER ] JOIN
  RIGHT [ OUTER ] JOIN
  FULL [ OUTER ] JOIN

  JOIN文法範例如下所示。

  method:postlogstorelogs | select count(1) , histogram(logstore) from log  l join sls_join_meta_store m on l.projectid = cast( m.ikey as varchar)

儲存查詢分析結果到MySQL資料庫

MySQL資料庫表的欄位是varchar，需要將日誌庫的欄位轉換為MySQL表的欄位。例如MySQL表的欄位detail為varchar(60)，在Logstore中將索引content用cast函數轉換：cast(content as varchar(60))。cast函數請參見類型轉換函式。

Log Service支援通過Insert文法將查詢結果插入到MySQL資料庫中。Insert文法範例如下所示：

method:postlogstorelogs | insert into join_meta  select cast(method as varchar(65535)),count(1) from log group by method

Python程式範例

# encoding: utf-8
from __future__ import print_function
from aliyun.log import *
from aliyun.log.util import base64_encodestring
from random import randint
import time
import os
from datetime import datetime
    endpoint = os.environ.get('ALIYUN_LOG_SAMPLE_ENDPOINT', 'cn-chengdu.log.aliyuncs.com')
    accessKeyId = os.environ.get('ALIYUN_LOG_SAMPLE_ACCESSID', '')
    accessKey = os.environ.get('ALIYUN_LOG_SAMPLE_ACCESSKEY', '')
    logstore = os.environ.get('ALIYUN_LOG_SAMPLE_LOGSTORE', '')
    project = "ali-yunlei-chengdu"
    client = LogClient(endpoint, accessKeyId, accessKey, '')
    #建立ExternalStore。
    res = client.create_external_store(project,
                                       ExternalStoreConfig(externalStoreName="rds_store", region="cn-chengdu",
                                                           storeType="rds-vpc",
                                                           vpcId="vpc-2vctx8reuqswmk********",
                                                           host='rm-2vc6x67972iv********.mysql.cn-chengdu.rds.aliyuncs.com',
                                                           port="3306", username="root", password="123456",
                                                           database="test_database", table="test"))
    res.log_print()
    #擷取ExternalStore詳情。
    res = client.get_external_store(project,"rds_store")
    res.log_print()
    res = client.list_external_store(project,"")
    res.log_print()
    # JOIN查詢。
    req = GetLogsRequest(project,logstore,From,To,"","* | select count(1) from  "+ logstore +"  s join  meta m on  s.projectid = cast(m.ikey as varchar)")
    res = client.get_logs(req)
    res.log_print()
     # 將查詢和分析結果寫入MySQL資料庫。
    req = GetLogsRequest(project,logstore,From,To,"","* |  insert into rds_store select count(1) from  "+ logstore )
    res = client.get_logs(req)
    res.log_print()