異なるソースからメッセージを受信しており、単一のメッセージにまとめたい。 たとえば、3つの異なるセンサーが発する値を、単一のデータベースのエントリとして登録したい場合。
各ストリームに一意の msg.topic
を指定して、
Join
ノードを使用して単一のメッセージにまとめます。
例のフローでは、それぞれの Inject
ノードは異なるメッセージ送信元を表しています。
それらは、別々の msg.topic
に値をセットしており、後続のフローで識別されます。
Join
ノードは msg.topic
をキー名として、
key/valueオブジェクトを生成するよう手動で設定されています。
すでにご存知のとおり、結合すべき3つの独立したメッセージのストリームが存在し、
ノードは指定数のメッセージパーツを受信後にメッセージを送信します。
各3つの異なるtopicに少なくとも1つのメッセージを受信するたびに、 各topicの最新の値を使用してメッセージを送信することを意味します。
{
"temperature":10,
"humidity":0,
"pressure":999
}
このノードにはさらに、レシピ内で使用されていない場合の挙動を変更するオプションを持っています。 たとえば、タイムアウトを設定し、センサーのひとつが値送信を停止した場合でも、 何かしらのメッセージが送信されることを担保するする場合などです。 これが問題ある場合は、このレシピを参考にプレースホルダーとなる値を送信することを検討してみてください。
Node-RED: Low-code programming for event-driven applications.
Copyright OpenJS Foundation and Node-RED contributors. All rights reserved. The OpenJS Foundation has registered trademarks and uses trademarks. For a list of trademarks of the OpenJS Foundation, please see our Trademark Policy and Trademark List. Trademarks and logos not indicated on the list of OpenJS Foundation trademarks are trademarks™ or registered® trademarks of their respective holders. Use of them does not imply any affiliation with or endorsement by them.
The OpenJS Foundation | Terms of Use | Privacy Policy | OpenJS Foundation Bylaws | Trademark Policy | Trademark List | Cookie Policy