データモデル

入力ストリーム

一般的な構造

入力ストリームの構造はすべて同様です。

型

より簡単にアクセスする方法として、APIに定義されたパラメータを介してアクセスすることで、それぞれのストリームのデータ型の payloadを直接受け取れます。

マネージドオブジェクト

クラス： com.cumulocity.model.ManagedObject

親や子への参照の Object[] に含まれるのはIDのみです。キャスト関数を使用できます。例：cast(event.managedObject.childAssets[0], com.cumulocity.model.ID).

例：

select
  event.managedObject.id,
  event.managedObject.type,
  event.managedObject.name,
  event.managedObject.lastUpdated,
  event.managedObject.owner,
  event.managedObject.childAssets,
  event.managedObject.assetParents,
  event.managedObject.deviceParents,
  event.managedObject.childDevices
from ManagedObjectCreated event;

イベント

クラス： com.cumulocity.model.event.Event

例：

select
  event.event.id,
  event.event.creationTime,
  event.event.type,
  event.event.text,
  event.event.time,
  event.event.source
from EventCreated event;

メジャーメント

クラス: com.cumulocity.model.measurement.Measurement

例:

select
  event.measurement.id,
  event.measurement.type,
  event.measurement.time,
  event.measurement.source
from MeasurementCreated event;

オペレーション

クラス： com.cumulocity.model.operation.Operation

例：

select
  event.operation.id,
  event.operation.creationTime,
  event.operation.status,
  event.operation.deviceId
from OperationCreated event;

アラーム

クラス: com.cumulocity.model.event.Alarm

例：

select
  event.alarm.id,
  event.alarm.creationTime,
  event.alarm.type,
  event.alarm.count,
  event.alarm.severity,
  event.alarm.status,
  event.alarm.text,
  event.alarm.time,
  event.alarm.source
from AlarmCreated event;

出力ストリーム

一般的な構造

出力ストリームによって、 Things Cloud のデータに対して CREATE, UPDATE, DELETE を行うことができます。 データの更新や削除を行う場合、対象となるオブジェクトのIDを準備する必要があります。 データを生成する時にイベント処理でIDの設定がされていない場合、Things Cloud がIDを生成します。また、データ生成では（REST APIと同様）特定のパラメータをいくつか設定する必要があります。 下記の既定パラメータに加え、自由にカスタムフラグメントを追加することもできます。カスタムフラグメントの追加については、フラグメントのカスタマイズ セクションをご覧ください。

注記： 独自のID登録はマネージドオブジェクトのみ可能です。

マネージドオブジェクト

例：

insert into CreateManagedObject
select
  "myManagedObject" as name,
  "myType" as type
from EventCreated event;

insert into UpdateManagedObject
select
  "12345" as id,
  "myNewManagedObject" as name
from EventCreated event;

insert into DeleteManagedObject
select
  "12345" as id
from EventCreated event;

イベント

例：

insert into CreateEvent
select
  "copiedEventType" as type,
  "This event was copied" as text,
  event.event.time as time,
  event.event.source as source
from EventCreated event;

insert into DeleteEvent
select
  "12345" as id
from EventCreated event;

メジャーメント

例：

insert into CreateMeasurement
select
  "c8y_TemperatureMeasurement" as type,
  event.event.time as time,
  event.event.source as source,
  {
    "c8y_TemperatureMeasurement.T.value", 5
  } as fragments
from EventCreated event;

insert into DeleteMeasurement
select
  "12345" as id
from EventCreated event;

オペレーション

例：

insert into CreateOperation
select
  OperationStatus.PENDING as status,
  event.event.source as deviceId,
  {
    "c8y_Restart", {}
  } as fragments
from EventCreated event;

insert into UpdateOperation
select
  "12345" as id,
  OperationStatus.EXECUTING as status
from EventCreated event;

アラーム

例：

insert into CreateAlarm
select
  "c8y_HighTemperatureAlarm" as type,
  event.event.time as time,
  event.event.source as source,
  CumulocitySeverities.WARNING as severity,
  CumulocityAlarmStatuses.ACTIVE as status,
  "The device has high temperature" as text
from EventCreated event;

insert into UpdateAlarmn
select
  "12345" as id,
  CumulocityAlarmStatuses.ACKNOWLEDGED as status
from EventCreated event;

特殊なストリーム

この章で触れるストリームは Things Cloud のデータベースにアクセスせず、外部サービスの起動を行います。

SendMail

receiver, cc, bcc には複数のメールアドレスを設定できます。それには、コンマ区切りですべてのメールアドレスを含んだ文字列を設定してください。 例　receiver1@mail.com,receiver2@mail.com

例：

insert into SendEmail
select
  "receiver1@cumulocity.com,receiver2@cumulocity.com" as receiver,
  "cc@cumulocity.com" as cc,
  "bcc@cumulocity.com" as bcc,
  "reply@cumulocity.com" as replyTo,
  "Example mail" as subject,
  "This mail was sent to test the SendEmail stream in Cumulocity" as text
from AlarmCreated;

SendExport

このストリームにより、エクスポートを生成することができます。

例：

insert into SendExport
select
    'configurationExportId' as enabledSources,
    'subject' as subject,
    'text' as text,
    'receiver@example.com' as receiver
from
    pattern [every timer:at(5, *, *, *, *)]

追加のデータモデル

ID

クラス： com.cumulocity.model.ID

例：

select
  event.measurement.source.value,
  event.measurement.source.type,
  event.measurement.source.name
from MeasurementCreated event;

OperationStatus

クラス： com.cumulocity.model.operation.OperationStatus

OperationStatus は次のような列挙型です： PENDING, SUCCESSFUL, FAILED, EXECUTING

例：

insert into UpdateOperation
select
  event.operation.id.value as id,
  OperationStatus.FAILED as status
from OperationCreated event;

Severity(重大度)

クラス： com.cumulocity.model.event.Severity

Severity は CumulocitySeverities で定義される列挙型です。CumulocitySeverities は次の値を提供します： CRITICAL, MAJOR, MINOR, WARNING

例：

insert into UpdateAlarm
select
  event.alarm.id.value as id,
  CumulocitySeverities.MAJOR as severity
from AlarmCreated event;

AlarmStatus

クラス： com.cumulocity.model.event.AlarmStatus

AlarmStatus は、CumulocityAlarmStatuses で定義される列挙型です。CumulocityAlarmStatuses は次の値を提供します： ACTIVE, ACKNOWLEDGED, CLEARED

例：

insert into UpdateAlarm
select
  event.alarm.id.value as id,
  CumulocityAlarmStatuses.ACKNOWLEDGED as status
from AlarmCreated event;