---
title: CloudStreamデータソースの管理
description: この記事では、CloudStreamデータソースの管理方法について説明します。
url: https://docs.tealium.com/ja/server-side/cloudstream/datasources/
---
## 動作原理

データソースは、SnowflakeやDatabricksなどのデータクラウドへの定義済み接続です。CloudStreamはこれらのデータソースに接続してセグメントを取得し、Tealiumにデータを保存せずにアクティベーションします。これにより、既存のデータインフラの力を活用しながら、クラウドから直接大規模なデータセットを扱うことができます。

![](https://docs.tealium.com/images/early-access/cloudstream/cloudstream_datasource_summary.png)


<blockquote>
プロファイルで最大10個のデータソースに接続できます。
</blockquote>


CloudStreamデータソースは、データクラウドに保存されているデータと直接連携するように設計されています。データはデータクラウドに残り、コネクタを通じて一時的にインポートされるだけで、Tealiumには保存されません。


<blockquote>
CloudStreamはクラウドデータソースのみをサポートしています。
</blockquote>


クラウドデータソースについての詳細は、[about-cloud-data-sources](https://docs.tealium.com/about-cloud-data-sources/)を参照してください。

## 構成のテスト

データソース、セグメント、またはアクティベーションを有効にする前に、データソースとクエリをテストすることをお勧めします。ただし、テストを実行すると、セグメントがアクティブ化され、有効なアクションがトリガーされ、下流のシステムに影響を与える可能性があります。意図しない結果を防ぐために、コネクタと機能を無効にし、テストレコードを制限し、受信者と調整してください。

データソース構成をテストするには、次の手順を使用します：

![](https://docs.tealium.com/images/early-access/cloudstream/cloudstream_test_configuration.png)

1. データソースウィンドウの右上隅にあるアクションボタンをクリックし、**エンドツーエンドテスト**をクリックします。
1. 出力を受け取る方法を選択します：
    * **新しいトレースセッション**：出力は最大10レコードの新しいトレースセッションで表示されます。このオプションは、エンドツーエンドの検証とログの詳細を確認するのに最適です。
    * **既存のトレースセッション**：すでに開始しているトレースセッションで出力が表示されます。**トレースID**を入力し、**トレースに参加**をクリックします。
    * **ダイレクト出力**：生の結果が画面に表示されます。データレコードにトレースIDは追加されず、トレースは利用できません。このオプションは、クエリと属性マッピングをすばやく確認するのに最適です。
1. テストのために処理する行数を選択します。最大行数は10です。
1. **テストクエリ**の下で、テストに含めるテーブルのカラムを選択します。リストからカラムを削除するには、カラムの**X**をクリックします。少なくとも1つのカラムを選択する必要があります。
1. **From Table**の下で、クエリを実行するテーブルを選択します。**Select Columns**ボックスは、テーブルのカラムで更新されます。
1. **Where**の下で、テーブルに対して実行するSQLクエリを入力します。
1. **Check Query**をクリックしてSQLを検証し、必要なフィールドが構成されていることを確認します。結果は**Query Result Preview**タブの下のテーブルに表示されます：![](https://docs.tealium.com/images/early-access/cloudstream/cloudstream_test_check_query.png)
1. **Start Test**をクリックして構成テストを開始します。

右サイドバーには、テストの完了までの時間を推定するプログレスバーと、テストがエラーに遭遇した場合に知らせるステータスメッセージが表示されます。

![](https://docs.tealium.com/images/early-access/cloudstream/cloudstream_test_output.png)

テストが完了すると、結果が表示されます：

![](https://docs.tealium.com/images/early-access/cloudstream/cloudstream_test_results.png)

* テストの実行をトレースで見たい場合は、**Join Trace**をクリックします。
* テストが失敗した場合は、次のことができます：
     * **Edit Test Configuration**をクリックして構成を変更します。
     * **Retry Test**をクリックして現在の構成を再実行します。

## オフセットの管理

データソースは、クエリが開始される日付または増分値の位置を追跡します。オフセットをリセットまたは手動で構成することで、ビューまたはテーブルのどこからクエリを開始するかを制御できます。

たとえば、最近のメーリングリストのアクティベーションにエラーが含まれており、100レコードが処理された場合、現在の増分オフセットは342です。メールアクティベーションを修正した後、これらのレコードを再処理するには、オフセットを242に構成します。データソースを再起動すると、その位置からレコードのクエリが開始され、修正されたメールが送信されます。

次の条件が真の場合にのみ、オフセットを管理できます：

* 現在のプロファイルが公開されています。
* クエリモードが**Timestamp + Incrementing (推奨)**、**Timestamp**、または**Incrementing**です。**Full Resync**クエリモードではオフセットを管理できません。
* データソースが停止しています。
    * データソースの状態が実行中、スケジュールされている、または失敗している場合は、オフセットを編集できません。現在のオフセットに関する情報のみが利用可能です。
    * 状態が初期化中、非アクティブ、または接続エラーがある場合、オフセットは利用できません。

データソースのオフセットを管理するには、次の手順を使用します：

![](https://docs.tealium.com/images/early-access/cloudstream/manage_offset.png)

1. データソースの詳細ウィンドウの右上隅にあるアクションボタンをクリックし、**Manage Offset**をクリックします。
1. 利用可能なオフセット方法は**Timestamp**と**Incrementing Column**です。クエリモードによって利用可能なオフセットが決まります。
1. **Timestamp Column**の下で、タイムスタンプを表すテーブルのカラムを選択します。
1. **New Timestamp**の下で、データをインポートする際にタイムスタンプからオフセットする日付と時間を選択します。
    * 新しいタイムスタンプは過去の日時でなければなりません。未来の日時は使用できません。
    * 現在のタイムスタンプフィールドには、現在使用されているオフセットが表示されます。
1. **Incrementing column**の下で、テーブルに追加される各行の増分値を表すカラムを選択します。
1. **New Increment**の下で、データをインポートする際にIDからオフセットする数値を入力します。
    * 新しいオフセットIDは正の整数でなければなりません。
    * 現在のオフセットIDフィールドには、オフセットとして使用される現在の数値が表示されます。

**Validate Offset Changes**をクリックして、新しいオフセット位置からインポートされるデータのプレビューを表示します。テーブルはサンプル行を表示し、オフセットを調整した後に処理される行数の見積もりも提供します。

![](https://docs.tealium.com/images/early-access/cloudstream/validate_offset.png)

**Done**をクリックして新しいオフセット構成を確認します。**Cancel**をクリックして変更を破棄します。

オフセットを変更した後、データソースを再起動します。