永続的な Pilot Protocol 接続を使用して、agent 間でリアルタイムの NDJSON データ転送を行うための高性能ストリーミングスキルです。
インストール＆ダウンロード
1. ClawHub CLI
レジストリから直接スキルをインストールする最速の方法です。
npx clawhub@latest install pilot-stream-data
2. 手動インストール
スキルフォルダを以下のいずれかの場所にコピーしてください
~/.openclaw/skills/ <project>/skills/ 優先順位：ワークスペース > ローカル > バンドル
3. プロンプトのインストール
このプロンプトをOpenClawにコピーするだけで、自動的にインストールされます。
Clawhubを使って pilot-stream-data をインストールして。Clawhubがインストールされていない場合は、先にインストールしてください（npm i -g clawhub）。
ダウンロードをご希望ですか？
ZIPアーカイブで生のスキルファイルを取得します。
pilot-stream-data とは？
pilot-stream-data スキルは、低遅延で構造化されたデータ転送のために設計された Openclaw Skills エコシステム内の特殊なツールです。Pilot Protocol の永続接続を活用することで、AI agent やシステムプロセスが NDJSON (Newline Delimited JSON) 形式で継続的な情報ストリームを交換することを可能にします。このアプローチは、ログやセンサーの読み取り値のような高頻度データに対して、標準的なリクエスト/レスポンスサイクルよりも大幅に効率的です。
信頼性とスケーラビリティを考慮して構築されたこのスキルには、バックプレッシャ処理のネイティブサポートが含まれており、トラフィックのピーク時にデータプロデューサーがコンシューマーを圧倒しないようにします。分散型モニタリングネットワークを構築する場合でも、マルチエージェントのコラボレーション環境を構築する場合でも、pilot-stream-data は最新の Openclaw Skills 実装に必要な堅牢なトランスポート層を提供します。
pilot-stream-data のユースケース
- agent 間でのセンサーテレメトリや IoT デバイスメトリクスのリアルタイム転送。
- ライブデバッグのためのシステムログやアプリケーショントレースの継続的なストリーミング。
- 低遅延の更新を必要とする同期タスクのためのエージェント間通信。
- 断続的なポーリングよりも永続的な接続が好まれる双方向データフロー。
pilot-stream-data の仕組み
- 受信側 agent は、pilotctl ユーティリティを使用して特定の Pilot Port でリスナーを初期化します。
- 送信側 agent は、ターゲットの宛先 ID とポートへの永続的な接続を確立します。
- データは個々の JSON オブジェクトにシリアル化され、改行が追加されて NDJSON ストリームが形成されます。
- Pilot Protocol が基盤となるトランスポートを管理し、ストリームの整合性を維持するためにフロー制御とバックプレッシャを処理します。
- コンシューマー agent は、通常 jq などのツールを使用して、受信ストリームを 1 行ずつリアルタイムで解析します。
pilot-stream-data のセットアップ
この Openclaw Skills モジュールを使用するには、pilot-protocol がインストールされ、デーモンが実行されていることを確認してください。
# Start the pilot protocol daemon
pilotctl daemon start
# Ensure dependencies are available
sudo apt-get install jq bc
# Initialize a listener to test the setup
pilotctl --json listen 1002
pilot-stream-data のデータスキーマとタクソノミー
このスキルは NDJSON に基づくストリーミングスキーマを利用します。すべてのメッセージは独立した JSON オブジェクトです。典型的なデータ構造は以下の通りです：
| Field | Type | Description |
|---|---|---|
| type | string | メッセージタイプ（例：'data', 'stream_start', 'heartbeat'） |
| timestamp | integer | イベントの Unix epoch タイムスタンプ |
| seq | integer | パケット損失検出のための増分シーケンス番号 |
| payload | object | カスタムデータフィールド（例：temp, humidity, status） |
標準的なストリーミングは、{"type":"data","timestamp":1715234400,"value":23.5} に続いて改行 \n が来るパターンに従います。
pilot-stream-data の高度な機能
- 大容量のバースト時にメモリオーバーフローを防止するネイティブバックプレッシャ処理。
- データ転送開始前のスキーマ交渉のためのメタデータヘッダーサポート。
- 帯域幅を節約するためのオプションのオンザフライストリーム圧縮のための Gzip 統合。
- ネットワーク全体での柔軟なデータルーティングのための購読ベースのストリームトピック。
SKILL.md
ローディング
関連するOpenclawのスキル
pilot-swarm-config
バージョン管理、アトミック更新、およびロールバック機能を備えた、AIエージェントスウォームのための分散構成管理システムです。
Pilot Slack Bridge
Pilot Protocol エージェントと Slack ワークスペースを接続し、リアルタイム通知と自動イベント処理を実現する双方向統合ブリッジ。
ClickHouse ベストプラクティス
ClickHouseデータベースのスキーマ設計、クエリパフォーマンスチューニング、および高スループットのデータ取り込みのための包括的な最適化エキスパートスキルです。
Donglun Poster
Dongfang Hotline (Cnool) フォーラムとやり取りするための専門的な自動化ツールであり、シームレスな投稿、返信、トレンドトピックの閲覧を可能にします。
特徴*
