Simple Log Service:JDBC を使用して Simple Log Service に接続する

背景情報

MySQL は一般的なリレーショナルデータベースサービスです。多くのソフトウェア製品が、MySQL プロトコルと SQL 構文を使用して MySQL データを取得できます。JDBC を使用して Simple Log Service に接続するには、SQL 構文に精通している必要があります。Simple Log Service では、MySQL プロトコルに基づいてログをクエリおよび分析できます。標準の MySQL クライアントを使用して Simple Log Service に接続できます。その後、標準の SQL 構文を使用してログをクエリおよび分析できます。MySQL クライアント、JDBC、MySQL Connector などのクライアントが MySQL プロトコルをサポートしています。

制限事項

• Simple Log Service は JDBC 5.1.49 のみをサポートしています。

• Java で JDBC、Python で MySQL Connector などのドライバーを使用して Simple Log Service にアクセスする場合は、Simple Log Service の内部エンドポイントのみを使用する必要があります。内部エンドポイントは、Alibaba Cloud のクラシックネットワークまたは仮想プライベートクラウド (VPC) 経由でアクセスできます。詳細については、「エンドポイント」をご参照ください。別のエンドポイントを使用すると、次のエラーが発生します: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure,Caused by: java.net.ConnectException: Connection timed out: connect。

サンプルログ

バイクシェアサービスの各ログには、ユーザーに関する情報が含まれています。情報には、年齢、性別、バッテリー使用量、自転車 ID、操作レイテンシ、緯度、ロックタイプ、経度、操作タイプ、操作結果、ロック解除タイプが含まれます。ログは、シンガポールリージョンにある trip-demo プロジェクトの ebike ログストアに保存されます。

Time :10-12 14:26:44
__source__: 192.168.0.0
__topic__: v1 
age: 55 
battery: 118497.673842 
bikeid: 36 
gender: male 
latency: 17 
latitude: 30.2931185245 
lock_type: smart_lock 
longitude: 120.052840484 
op: unlock 
op_result: ok 
open_lock: bluetooth 
userid: 292

JDBC ベースのクエリと分析

1. Maven プロジェクトを作成し、プロジェクトの pom.xml ファイルに次の JDBC 依存関係を追加します。サンプルコード:

   <dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.49</version>
   </dependency>

2. JDBC を使用してログをクエリする Java プログラムを作成します。次のサンプルコードは、JDBC を使用してログをクエリする Java プログラムを作成する方法を示しています。

   重要

   • WHERE 句に __date__ または __time__ フィールドを含めて、クエリの時間範囲を制限する必要があります。__date__ フィールドのデータ型はタイムスタンプです。__time__ フィールドのデータ型は bigint です。例:

     • __date__ > '2017-08-07 00:00:00' and __date__ < '2017-08-08 00:00:00'

     • __time__ > 1502691923 and __time__ < 1502692923

   • JDBC 接続形式: jdbc:mysql://{project}.{endpoint}:10005/{project}。{project} および {endpoint} の詳細については、「パラメータの説明」をご参照ください。

   /**
   * Created by xxx on 2017/6/19.
   */
   import com.mysql.jdbc.*;
   import java.sql.*;
   import java.sql.Connection;
   import java.sql.Statement;
   /**
   * Created by xxx on 2017/6/15.
   */
   public class CollectTest {
    public static void main(String args[]){
        // Simple Log Service のプロジェクト名と内部エンドポイント。名前とエンドポイントを実際の値に置き換えます。
        final String endpoint = "ap-southeast-1-intranet.log.aliyuncs.com";
        // JDBC ベースのアクセスに使用されるポート。デフォルトポートは 10005 です。
        final String port = "10005";
        // Simple Log Service プロジェクトの名前。
        final String project = "trip-demo";
        // Simple Log Service ログストアの名前。
        final String logstore = "ebike";
        // この例では、AccessKey ID と AccessKey シークレットは環境変数から取得されます。
        final String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
        final String accessKey = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
        Connection conn = null;
        Statement stmt = null;
        try {
            // ステップ 1: JDBC ドライバーを読み込みます。
            Class.forName("com.mysql.jdbc.Driver");
            // ステップ 2: 接続文字列を作成します。
            conn = DriverManager.getConnection("jdbc:mysql://"+endpoint+":"+port+"/"+project+"?useSSL=false",accessKeyId,accessKey);
            // ステップ 3: ステートメントを作成します。
            stmt = conn.createStatement();
            // ステップ 4: 2017 年 10 月 11 日に生成され、op フィールドが unlock に設定されているログの数をクエリするクエリ文を指定します。
            String sql = "select count(1) as pv,avg(latency) as avg_latency from "+logstore+"  " +
                    "where     __date__  >=  '2017-10-11 00:00:00'   " +
                    "     and  __date__  <   '2017-10-12 00:00:00'" +
                    " and     op ='unlock'";
            // ステップ 5: クエリ文を実行します。
            ResultSet rs = stmt.executeQuery(sql);
            // ステップ 6: クエリと分析の結果を抽出します。
            while(rs.next()){
                // 列名で取得します
                System.out.print("pv:");
                // 結果に pv を表示します。
                System.out.print(rs.getLong("pv"));
                System.out.print(" ; avg_latency:");
                // 結果に avg_latency を表示します。
                System.out.println(rs.getDouble("avg_latency"));
                System.out.println();
            }
            rs.close();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
   }