SCADAInput ノード

このトピックには、以下のセクションが含まれています。

目的

WebSphere MQ Telemetry Transport を介してブローカーに接続するクライアントからのメッセージを受信するには、SCADAInput ノードを使用します。 SCADA デバイス・クライアントは、MQIsdp プロトコルを使用して、SCADAInput ノードが WebSphere Event Broker によって認識される形式に変換するメッセージを送信します。 このノードは、これらのメッセージの処理環境も確立します。

SCADA デバイスから受信するメッセージを処理するメッセージ・フローは、常に SCADAInput ノードから開始されます。SCADAInput ノードのプロパティーを設定すると、メッセージの受信方法を制御できます。 例えば、メッセージをトランザクション制御下で処理するように指示できます。

SCADA ノードを含むメッセージ・フローをブローカーにデプロイする場合、メッセージ・フローの数にかかわりなく、単一の実行グループにデプロイする必要があります。

SCADA は主にパブリッシュ/サブスクライブなので、通常 Publication ノードを組み込んでフローを終了します。 Publication ノードを組み込みたくないシナリオの場合には、SCADAOutput ノードを組み込むことができます。 そうする場合には、メッセージのソースにかかわらず SCADAInput ノードも組み込む必要があります。 SCADAInput ノードは、SCADAOutput ノードが必要とする接続情報を提供するからです。

SCADAInput ノードで開始されるメッセージ・フローに出力ノードを組み込む場合には、サポートされるいずれかの出力ノード (ユーザー定義の出力ノードも含む) を使用できます。 必要な任意の変換を提供するようにブローカーに要求するようにメッセージ・フローを構成できますので、SCADA デバイスからメッセージを受け取り、サポートされるトランスポートすべてを使用してブローカーに接続するクライアント用のメッセージを生成する、メッセージ・フローを作成できます。

特定のトピックのメッセージをパブリッシュして、ブローカーが SCADA リスナーを開始または停止するように要求できます。これは、すべてのポートまたはメッセージ内で識別される単一ポートに対して行うことができます。

z/OS システム上にデプロイされるメッセージ・フロー中で、SCADAInput ノードを使用することはできません。

サブフローとして使用するメッセージ・フローを作成する場合には、標準入力ノードを使用することはできず、入力ノードのインスタンスを最初のノードとして使用して、サブフロー用の in ターミナルを作成する必要があります。

ご使用のメッセージ・フローが SCADA 接続を経由してメッセージを受け取らない場合には、サポートされる入力ノードのいずれかを選択できます。

ワークベンチでは、SCADAInput ノードは次のアイコンで表されます。

SCADAInput ノード・アイコン

メッセージ・フロー内でのこのノードの使用

このノードの使用方法の例として、リモート・センサーが操作環境の変化 (屋外温度の低下など) を検出した場合に、リモート・センサーからのメッセージを受信するメッセージ・フローを、SCADAInput ノードを使って作成すると想定します。 このノードを MQOutput ノードに接続します。MQOutput ノードは、これらのメッセージを WebSphere MQ アプリケーションがサービスするキューで使用可能にします。 このアプリケーションは、受信した情報を分析して、これに応答します。

SCADAInput ノードの構成

SCADAInput ノードのインスタンスをメッセージ・フローに入れると、SCADAInput ノードを構成することができます。 エディター・ビューでノードを右クリックし、「プロパティー」をクリックします。ノードの基本プロパティーが、プロパティー・ダイアログに表示されます。

値を入力する必要のある (デフォルト値が定義されていない) すべての必須プロパティーには、プロパティー・ダイアログにアスタリスクが表示されます。

以下のように、SCADAInput ノードを構成します。

  1. 以下のように基本プロパティーを設定します。
    1. 始動時にリスナーを使用可能にする」チェック・ボックスは、最初から選択されています。 これは、メッセージ・フローがデプロイされたときに MQIsdp クライアントのリスナーが初期化されることを意味します。

      メッセージ・セットのペイロード部分を「オン」または「オフ」にセットした制御トピック $SYS/SCADA/MQIsdpListener/<port_number> でパブリッシュすることによって、リスナーの状況を更新することができます。

    2. MQIsdp サーバーが listen する「ポート」番号を指定します。 これは固有のポートにする必要があります。 他のリスナー (例えば、WebSphere MQ または WebSphere MQ Everyplace 用に設定されているリスナー) と競合しないようにしてください。 デフォルト番号は、1883 です。
    3. スレッドの最大数」の値を設定して、MQIsdp サーバーが クライアントをサポートするために処理できるスレッドの最大数を示します。 デフォルト値は 500 です。

      ブローカー・データベースとして DB2 を使用している場合、DB2 構成パラメーター maxappls および maxagents に設定した値以下の値を指定する必要があります。 詳細は、データベースへのアクセスの構成を参照してください。

    4. 変更の始まりクライアントにサービスを提供するために、ノードにスレッドのプールを使用させたい場合は、「スレッド・プーリングを使用する」を選択します。 このオプションを選択した場合、MQIsdp サーバーで使用可能なスレッド数は「スレッドの最大数」によって制限されます。この値を、20 から 40 の間に設定することをお勧めします。このオプションを選択しない場合、接続されるクライアントごとに新しいスレッドが作成されます。 最初、このチェック・ボックスはチェックされています。

      多くのクライアント (200 を超えるクライアント) が接続する場合にのみ、このオプションを使用します。

      変更の終わり
  2. プロパティー・ダイアログ・ナビゲーターで「拡張」を選択し、「トランザクション・モード」に必要な値を設定して、このメッセージの処理方法についてのトランザクション特性を定義します。
    • 「自動」を選択した場合、着信メッセージに持続のマークが付けられている場合に同期点下で受信され、そうでないときは受信されません。出力ノードによってその後に送信される派生メッセージのトランザクション特性は、出力ノードが明示的にトランザクション特性をオーバーライドしない限り、着信持続プロパティーによって判別されます。
    • 「はい」を選択すると、着信メッセージが同期点下で受信されます。 メッセージ・フローと同じインスタンスの出力ノードによってその後に送信される派生メッセージは、出力ノードが明示的にトランザクションをオーバーライドしない限り、トランザクションとして送信されます。
    • 「いいえ」を選択すると、着信メッセージが同期点下で受信されません。 フローの出力ノードによってその後に送信される派生メッセージは、出力ノードがメッセージを同期点下に置くことを指定していない限り、非トランザクションとして送信されます。
  3. 簡略説明または詳細説明 (あるいはその両方) を入力するには、プロパティー・ダイアログ・ナビゲーターの「説明」を選択します。
  4. 「適用」をクリックすると、プロパティー・ダイアログを閉じずに SCADAInput ノードが変更されます。 「OK」をクリックすると、変更を適用してプロパティー・ダイアログを閉じます。

    「キャンセル」をクリックすると、ダイアログを閉じてプロパティーに対して行った変更をすべて破棄します。

ターミナルの接続

SCADAInput は、out ターミナルに正常に取り出される各メッセージをルーティングします。 これが失敗すると、メッセージは failure ターミナルに伝搬されます。 ノードをこのターミナルに接続し、この状態を処理することができます。 failure ターミナルに接続していなかった場合、その問題が解決されるまで、メッセージはこのノードでループし続けます。

メッセージ・フロー内でさらに例外がスローされた後、このノードによってメッセージがキャッチされる場合、メッセージは catch ターミナルにルーティングされます。 catch ターミナルに接続しなかった場合、その問題が解決されるまで、メッセージはこのノードでループし続けます。 メッセージがメッセージ・フロー内でロールバックする可能性がある場合には、ノードが常時このターミナルに接続されているようにしてください。

整合トランザクションの構成

メッセージ・フローに SCADAInput ノードを組み込む場合、「トランザクション・モード 」で設定する値が、メッセージを同期点下で受信するかどうかを定義します。

  • 「はい」(デフォルト) に設定した場合、メッセージは同期点下 (WebSphere MQ 作業単位内) で受信されます。 メッセージ・フローと同じインスタンスの出力ノードによってその後に送信されるメッセージは、出力ノードがこれを明示的にオーバーライドしない限り、同期点の下に置かれます。
  • 「自動」に設定した場合、メッセージは、着信メッセージに持続のマークが付けられている場合に同期点下で受信されます。そうでない場合、メッセージは同期点下で受信されません。 出力ノードによってその後に送信されるメッセージは、出力ノードがこれを明示的にオーバーライドしない限り、着信持続プロパティーによって判別されたとおりに同期点の下に置かれます。
  • 「いいえ」に設定した場合、メッセージは同期点下で受信されません。フロー内の出力ノードによってその後に送信されるメッセージは、個々の出力ノードがメッセージを同期点の下に置くように指定しない限り、同期点の下には置かれません。

(MQOutput ノードは出力ノードのみで、このオプションのオーバーライドを構成できます。)

ターミナルおよびプロパティー

SCADAInput ノード・ターミナルについては、次の表に説明されています。

ターミナル 説明
Failure エラーが発生した場合にメッセージがルーティングされる出力ターミナル。
Out キューからメッセージが正常に取り出された場合に、メッセージがルーティングされる出力ターミナル。
Catch 例外がダウンストリームでスローされ、ノードによってキャッチされた場合に、メッセージがルーティングされる出力ターミナル。

以下の表でノードのプロパティーを説明します。M の見出しの列は、プロパティーが必須 かどうかを示します (デフォルトが定義されていない場合に値を入力することが必要なら、プロパティー・ダイアログにアスタリスクのマークが付きます)。 C の見出しの列は、プロパティーが構成可能 かどうかを示します (メッセージ・フローを bar ファイルに追加してデプロイするとき、値を変更できます)。

SCADAInput ノードの「基本」プロパティーについては、次の表に説明されています。

プロパティー M C デフォルト 説明
始動時にリスナーを使用可能にする はい いいえ 選択されている リスナーを開始する時期。チェック・ボックスを選択した場合、メッセージ・フローがブローカーによって開始されるとリスナーが開始されます。チェック・ボックスを選択しない場合、指定されたポートにメッセージが到達するとリスナーが開始されます。
ポート はい はい 1883 SCADA プロトコルが listen するポート。
最大スレッド はい はい 500 SCADA デバイスをサポートするために始動するスレッドの最大数。
スレッド・プール使用 はい はい 選択されていない スレッド・プールを使用するかどうか。 チェック・ボックスを選択すると、このアクションが実行されます。

SCADAInput ノードの「拡張」プロパティーについては、次の表に説明されています。

プロパティー M C デフォルト 説明
トランザクション・モード はい いいえ 「はい」 着信メッセージが同期点下で受信されるかどうか。 有効な値は、「自動」「はい」、および「いいえ」です。

SCADAInput ノードの説明プロパティーについては、次の表に説明されています。

プロパティー M C デフォルト 説明
簡略説明 いいえ いいえ   ノードの簡単な説明
詳細説明 いいえ いいえ   メッセージ・フロー内のノードの目的を説明するテキスト
特記事項 | 商標 | ダウンロード | ライブラリー | サポート | フィードバック
Copyright IBM Corporation 1999, 2006 Last updated: 5 01, 2006
ac04620_