入力ポートでのデータ集約

SpeeDBee Synapse:v4.9.9最終更新日:2026-09-17

目的

複数コンポーネントからナノ秒単位でわずかに異なるタイムスタンプで届くデータを、指定したウィンドウ幅（ミリ秒）の区間ごとに1つのレコードへまとめて書き込む。

プロジェクトファイル

本事例で使用しているプロジェクトファイルです。通常版と、PLCコレクタをシミュレーションモードで設定した確認用ファイルを用意しています。

• InportAggregation.sspj
• InportAggregation_Sim.sspj (シミュレーションモード)

※SpeeDBee Synapseバージョン4.9.9以降でインポートできます。

このページで分かること

• 複数コンポーネントのデータが別々のレコードになる理由
• 入力ポート設定の集約機能を使ってデータを1つのレコードにまとめる方法

要件

PLC-AとPLC-Bに接続したPLCコレクタで、各PLCからtemperatureとpressureを収集し、CSVシリアライザの同じ入力ポートへ入力する。入力されたデータを設定したウィンドウ幅で区切り、各ウィンドウ区間内のデータを1つのレコードにまとめて出力する。

コンポーネント	データ	アドレス	内容
PLCコレクタ（PLC-A）	temperature	D0100	温度（℃）
PLCコレクタ（PLC-A）	pressure	D0101	圧力（kPa）
PLCコレクタ（PLC-B）	temperature	D0100	温度（℃）
PLCコレクタ（PLC-B）	pressure	D0101	圧力（kPa）

PLC-AとPLC-Bで同じ種類のデータを収集していても、PLCごとにデータを収集するタイミングは完全には一致しません。タイムスタンプはナノ秒単位で付与されるため、わずかなタイミング差によるタイムスタンプの違いでレコードが分かれます。

集約を設定しない場合、CSVシリアライザからは次のように出力されます。PLC-AとPLC-Bのデータが別々のタイムスタンプになっているため、各レコードには片方のPLCのデータだけが入ります。

timestamp	PLC-A:pressure	PLC-A:temperature	PLC-B:pressure	PLC-B:temperature
13:08:04.947378445+0900	68	25
13:08:04.949666433+0900			82	31
13:08:05.947378445+0900	68	25
13:08:05.949666433+0900			83	31

※日付部分（YYYY-MM-DD）は省略しています。

このように、タイムスタンプの異なるデータはレコードが分かれて出力されてしまうため、集約機能を使って同じウィンドウ区間内のデータを1つのレコードにまとめます。

使用するコンポーネント

• PLCコレクタ（PLC-AとPLC-Bからデータを収集）
• CSVシリアライザ（集約したデータをCSV化）

処理の流れ

1. PLCコレクタでPLC-AとPLC-Bのデータを収集
2. PLC-AとPLC-Bから収集したデータを、CSVシリアライザへ入力
3. CSVシリアライザの入力ポート設定の集約機能で、設定したウィンドウ幅で区切った各区間内のデータを同じレコードにまとめる
4. 集約したデータを、CSVの1つのレコードとして出力

設定方法

1. PLCコレクタを設定します。 PLC-AとPLC-Bそれぞれの接続先、収集対象のアドレス、データ型などを指定し、temperatureとpressureを収集できるようにします。 今回の設定では、各PLCのD0100をtemperatureとして、D0101をpressureとして収集します。

   

   

   厳密なタイムスタンプについて

   厳密なタイムスタンプをOFFにすると、同じコンポーネント内のデータに同じタイムスタンプが付与されます。ONにすると、同じPLCコレクタで収集したデータでも付与されるタイムスタンプが異なるため、レコードが分かれます。今回は、同じコンポーネント内のデータには共通のタイムスタンプを付与したいので、OFFにしています。

2. CSVシリアライザを設定します。 今回は、切替件数を10件に設定し、10レコードごとに1ファイルとして出力されるようにします。

   

3. CSVシリアライザ設定後、CSVシリアライザの入力ポートに各PLCコレクタを接続します。 複数のコンポーネントから同じ入力ポートへデータが入力される構成にします。

   

4. CSVシリアライザの入力ポートを右クリックして入力ポート設定を開き、集約するをONにします。 ウィンドウ幅を指定します。今回は1秒に設定し、各ウィンドウ区間内（1秒間）のデータを同じレコードにまとめます。

   

5. 入力されるデータに対して集約の設定を行います。今回は正規表現で対象を指定します。 コンポーネント名に.*、データ名に.*を指定し、CSVシリアライザに入力されるすべてのデータを対象にします。

   

6. 集約した値だけを出力するため、RAW DATAのチェックを外します。指定した入力データの集約トグルをクリックし、集約オプションから最新値を選択します。今回は、ウィンドウ区間内の最新値のみを使用します。

   

   

   集約オプションについて

   今回は最新値を使用していますが、100msなど短い間隔でデータを収集している場合や、ウィンドウ幅を大きめに設定している場合など、ウィンドウ区間内に多数のデータが含まれる場合は、算術平均などを代表値として選択することも有効です。データの用途に応じて、適切な集約オプションを選択してください。

7. 設定を保存し、各コンポーネントを起動します。

   

出力結果の確認

同じウィンドウ区間に含まれるデータは、CSVの1つのレコードとして出力されます。

集約後CSVのサンプルをダウンロード

以下は、集約後に出力されたCSVから一部のレコードを抜粋したものです。このように、各コンポーネントのデータに付与されたナノ秒単位のタイムスタンプが異なっていても、同じウィンドウ区間内のデータであれば1つのレコードにまとめて出力できます。

timestamp	PLC-A:pressure.newer	PLC-A:temperature.newer	PLC-B:pressure.newer	PLC-B:temperature.newer
14:37:13.551084040+0900	71	26	86	34
14:37:14.551084040+0900	71	26	87	34
14:37:15.551084040+0900	71	27	87	35
14:37:16.551084040+0900	72	27	88	35
14:37:17.551084040+0900	68	25	82	31
14:37:18.551084040+0900	68	25	83	31

※日付部分（YYYY-MM-DD）は省略しています。

タイムスタンプのミリ秒以下の値について

タイムスタンプのミリ秒以下の値は、Synapseのコンポーネントが処理を開始した時点を基準に決まります。そのため、タイムスタンプのミリ秒以下を0に揃えて出力することはできません。