Uma habilidade de streaming de alto desempenho para transmissão de dados NDJSON em tempo real entre agentes usando conexões persistentes Pilot Protocol.
Instalar e Baixar
1. ClawHub CLI
A maneira mais rápida de instalar uma habilidade diretamente do registro.
npx clawhub@latest install pilot-stream-data
2. Instalação Manual
Copie a pasta da habilidade para um desses locais
~/.openclaw/skills/ <project>/skills/ Prioridade: Espaço de Trabalho > Local > Integrado
3. Instalação do Prompt
Copie este prompt para o OpenClaw para instalá-lo automaticamente.
Ajude-me a instalar o pilot-stream-data usando o Clawhub. Se o Clawhub não estiver instalado, instale-o primeiro (npm i -g clawhub).
Prefere baixar?
Obtenha os arquivos originais da habilidade em um arquivo ZIP.
O que é pilot-stream-data?
A habilidade pilot-stream-data é uma ferramenta especializada dentro do ecossistema Openclaw Skills projetada para transmissão de dados estruturados de baixa latência. Ao aproveitar as conexões persistentes do Pilot Protocol, ela permite que agentes de AI e processos de sistema troquem fluxos contínuos de informações no formato Newline Delimited JSON (NDJSON). Esta abordagem é significativamente mais eficiente do que os ciclos padrão de requisição-resposta para dados de alta frequência, como logs ou leituras de sensores.
Construída para confiabilidade e escala, esta habilidade inclui suporte nativo para manipulação de backpressure, garantindo que os produtores de dados não sobrecarreguem os consumidores durante picos de tráfego. Esteja você construindo uma rede de monitoramento distribuída ou um ambiente colaborativo multi-agente, o pilot-stream-data fornece a camada de transporte robusta necessária para implementações modernas de Openclaw Skills.
Casos de uso do pilot-stream-data
- Transmissão em tempo real de telemetria de sensores e métricas de dispositivos IoT entre agentes.
- Streaming contínuo de logs do sistema ou rastreamentos de aplicativos para depuração ao vivo.
- Comunicação inter-agente para tarefas sincronizadas que exigem atualizações de baixa latência.
- Fluxos de dados bidirecionais onde a conectividade persistente é preferida em vez de polling intermitente.
Como o pilot-stream-data funciona
- O agente destinatário inicializa um listener em uma Pilot Port específica usando o utilitário pilotctl.
- O agente remetente estabelece uma conexão persistente com a identidade e porta de destino pretendidas.
- Os dados são serializados em objetos JSON individuais e acrescidos de quebras de linha para formar um fluxo NDJSON.
- O Pilot Protocol gerencia o transporte subjacente, lidando com controle de fluxo e backpressure para manter a integridade do fluxo.
- O agente consumidor processa o fluxo de entrada linha por linha, normalmente usando ferramentas como jq para parsing em tempo real.
Configuração do pilot-stream-data
Para usar este módulo Openclaw Skills, certifique-se de ter o pilot-protocol instalado e o daemon em execução.
# 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
Esquema de Dados e Taxonomia de pilot-stream-data
A habilidade utiliza um esquema de streaming baseado em NDJSON. Cada mensagem é um objeto JSON independente. Estruturas de dados típicas incluem:
| Field | Type | Description |
|---|---|---|
| type | string | O tipo de mensagem (ex: 'data', 'stream_start', 'heartbeat') |
| timestamp | integer | Timestamp Unix epoch do evento |
| seq | integer | Número de sequência incremental para detecção de perda de pacotes |
| payload | object | Campos de dados personalizados (ex: temp, humidity, status) |
O streaming padrão segue o padrão: {"type":"data","timestamp":1715234400,"value":23.5} seguido por uma quebra de linha \n.
Recursos avançados do pilot-stream-data
- Manipulação nativa de backpressure para evitar estouro de memória durante rajadas de alto volume.
- Suporte a cabeçalho de metadados para negociação de esquema antes do início da transmissão de dados.
- Integração com Gzip para compressão opcional de fluxo em tempo real para economizar largura de banda.
- Tópicos de fluxo baseados em assinatura para roteamento flexível de dados pela rede.
SKILL.md
Carregamento
Habilidades relacionadas do Openclaw
pilot-swarm-config
Um sistema de gerenciamento de configuração distribuído para enxames de agentes de IA, com controle de versão, atualizações atômicas e suporte a reversão.
Habilidade de Síntese de Vídeo
Um utilitário automatizado para mesclar vídeo, áudio e legendas em conteúdo profissional de formato curto vertical 9:16.
Pilot Slack Bridge
Uma ponte de integração bidirecional que conecta agentes do Pilot Protocol a espaços de trabalho do Slack para notificações em tempo real e processamento automatizado de eventos.
Melhores Práticas ClickHouse
Uma habilidade especializada em otimização abrangente para design de esquema de banco de dados ClickHouse, ajuste de desempenho de consulta e ingestão de dados de alta taxa de transferência.
Donglun Poster
Uma ferramenta de automação especializada para interagir com o fórum Dongfang Hotline (Cnool), permitindo postagens, respostas e navegação em tópicos populares sem interrupções.
Gerador Automático de Legendas
Um utilitário de alto desempenho para converter arquivos de áudio em legendas SRT com timestamp, sem dependências de API externas.
Apresentou*
