Tablestore:Tablestore SDK を使用して Tablestore データを OSS に配信する

使用上の注意

• データ配信は、中国 (杭州)、中国 (上海)、中国 (北京)、中国 (深セン)、中国 (張家口) リージョンでご利用いただけます。

• Tablestore データの削除操作は、データの配信時には無視されます。Tablestore データを削除操作を実行しても、OSS に配信された Tablestore データは削除されません。

• 配信タスクの作成時の初期化には最大 1 分かかります。

• データが一定の速度で書き込まれる場合、レイテンシは 3 分以内です。データが同期される場合、P99 レイテンシは 10 分以内です。

  説明

  P99 レイテンシは、過去 10 秒間のリクエストのうち最も遅い 1% の平均レイテンシを示します。

前提条件

• 以下の操作は、オブジェクトストレージサービス (OSS) コンソールで実行されます。

  OSS がアクティブ化されています。Tablestore インスタンスが存在するリージョンにバケットが作成されます。詳細については、OSS をアクティブ化する を参照してください。

  説明

  データ配信では、Tablestore インスタンスから、Tablestore インスタンスと同じリージョンにある OSS バケットにデータを配信できます。MaxCompute などの他のウェアハウスにデータを配信するには、チケットを送信してください。

• 以下の操作は、Tablestore コンソールで実行されます。

  • Tablestore インスタンスのエンドポイントは、[インスタンス管理] ページの [インスタンスの詳細] タブから取得します。詳細については、エンドポイント を参照してください。

  • データテーブルが作成されます。詳細については、データテーブルの操作 を参照してください。

• 以下の操作は、Resource Access Management (RAM) コンソールで実行されます。

  • RAM ユーザーが作成され、AliyunOTSFullAccess ポリシーが RAM ユーザーにアタッチされて、RAM ユーザーに Tablestore を管理する権限が付与されます。詳細については、RAM ユーザーの作成 および RAM ユーザーへの権限の付与 を参照してください。

    警告

    Alibaba Cloud アカウントの AccessKey ペアが漏洩した場合、リソースが潜在的なリスクにさらされます。操作を実行するには、RAM ユーザーの AccessKey ペアを使用することをお勧めします。これにより、Alibaba Cloud アカウントの AccessKey ペアの漏洩を防ぐことができます。

    RAM ユーザーの AccessKey ペアが作成されます。詳細については、AccessKey ペアの作成 を参照してください。

• アクセス認証情報が構成されます。詳細については、アクセス認証情報の構成 を参照してください。

操作

パラメーター

Tablestore SDK の使用

Tablestore SDK for Java および Tablestore SDK for Go を使用して、OSS にデータを配信できます。この例では、Tablestore SDK for Java を使用します。

次のサンプルコードは、データテーブルの配信タスクを作成する方法の例を示しています。

import com.alicloud.openservices.tablestore.ClientException;
import com.alicloud.openservices.tablestore.SyncClient;
import com.alicloud.openservices.tablestore.TableStoreException;
import com.alicloud.openservices.tablestore.model.delivery.*;
public class DeliveryTask {

        public static void main(String[] args) {
            final String endPoint = "https://yourinstancename.cn-hangzhou.ots.aliyuncs.com";

            final String accessKeyId = System.getenv("OTS_AK_ENV");
            
            final String accessKeySecret = System.getenv("OTS_SK_ENV");

            final String instanceName = "yourinstancename";

            SyncClient client = new SyncClient(endPoint, accessKeyId, accessKeySecret, instanceName);
            try {
                createDeliveryTask(client);
                System.out.println("end");
            } catch (TableStoreException e) {
                System.err.println("The operation failed. Details:" + e.getMessage() + e.getErrorCode() + e.toString()); // 操作に失敗しました。詳細：
                System.err.println("Request ID:" + e.getRequestId()); // リクエストID：
            } catch (ClientException e) {
                System.err.println("The request failed. Details:" + e.getMessage()); // リクエストに失敗しました。詳細：
            } finally {
                client.shutdown();
            }
        }

        private static void createDeliveryTask(SyncClient client){
            String tableName = "sampleTable";
            String taskName = "sampledeliverytask";
            OSSTaskConfig taskConfig = new OSSTaskConfig();
            taskConfig.setOssPrefix("sampledeliverytask/year=$yyyy/month=$MM");
            taskConfig.setOssBucket("datadeliverytest");
            taskConfig.setOssEndpoint("oss-cn-hangzhou.aliyuncs.com");
            taskConfig.setOssStsRole("acs:ram::17************45:role/aliyunserviceroleforotsdatadelivery");
            // The eventColumn parameter is optional. If you specify this parameter, data is partitioned based on the time of the data in the column that is specified by this parameter. If you do not specify this parameter, data is partitioned based on the time at which the data is written to Tablestore.  // eventColumn パラメーターはオプションです。このパラメーターを指定すると、このパラメーターで指定された列のデータの時刻に基づいてデータがパーティション化されます。このパラメーターを指定しない場合、データは Tablestore に書き込まれた時刻に基づいてパーティション化されます。
            EventColumn eventColumn = new EventColumn("Col1", EventTimeFormat.RFC1123);
            taskConfig.setEventTimeColumn(eventColumn);
            taskConfig.addParquetSchema(new ParquetSchema("PK1", "PK1", DataType.UTF8));
            taskConfig.addParquetSchema(new ParquetSchema("PK2", "PK2", DataType.BOOL));
            taskConfig.addParquetSchema(new ParquetSchema("Col1", "Col1", DataType.UTF8));
            CreateDeliveryTaskRequest request = new CreateDeliveryTaskRequest();
            request.setTableName(tableName);
            request.setTaskName(taskName);
            request.setTaskConfig(taskConfig);
            request.setTaskType(DeliveryTaskType.BASE_INC);
            CreateDeliveryTaskResponse response = client.createDeliveryTask(request);
            System.out.println("resquestID: "+ response.getRequestId()); // リクエストID：
            System.out.println("traceID: " + response.getTraceId()); // トレースID：
            System.out.println("create delivery task success"); // 配信タスクの作成に成功しました
        }
}