このトピックでは、LogHub データテーブルの使用方法について説明します。

構文

CREATE TABLE tbName(columnName dataType [,columnName dataType]*)
USING loghub
OPTIONS(propertyName=propertyValue[,propertyName=propertyValue]*);

設定パラメーター

パラメーター 説明 必須
sls.project Log Service プロジェクトの名前。 はい
sls.store Logstore の名前。 はい
access.key.id Alibaba Cloud によって提供される AccessKey ID。 はい
access.key.secret Alibaba Cloud によって提供される AccessKey Secret 。 はい
endpoint Log Service API のエンドポイント。 はい

テーブルスキーマ

LogHub データテーブルを作成するとき、 データテーブルのフィールドを明示的に定義する必要があります。 たとえば、有効なテーブル作成文は次のとおりです。
spark-sql> CREATE TABLE loghub_table_test
         > USING loghub
         > OPTIONS
         > (...)
これ以外の場合、次のエラーが返されます。
java.lang.IllegalArgumentException: requirement failed: Unable to infer the schema. The schema 
specification is required to create the table. ;
有効なテーブル作成文は次のとおりです。
spark-sql> CREATE TABLE loghub_table_test(content string)
         > USING loghub
         > OPTIONS
         > (...)

spark-sql> DESC loghub_table_test;
content  string  NULL
Time taken: 0.436 seconds, Fetched 1 row(s)