Skip to main content
Filtered Stream エンドポイントを使用すると、フィルタルールに一致する投稿をほぼリアルタイムで受信できます。強力な演算子を使ってルールを作成し、永続接続のストリームに接続して、投稿が公開された時点で一致する投稿を受信します。
Filtered Stream はデータのハイドレーションと配信を優先しており、P99 レイテンシは約 6〜7 秒です。より低いレイテンシが必要な場合は、Powerstream を参照してください。

概要

ニアリアルタイム配信

公開後数秒以内に投稿を受信

永続ルール

切断せずにルールを追加・削除

強力な演算子

キーワード、ハッシュタグ、ユーザーなどでマッチ

Webhook 配信

オプションで Webhook 経由で投稿を受信

しくみ

  1. ルールを作成 — 演算子を使ってフィルタルールを定義
  2. ストリームに接続 — 永続 HTTP 接続を確立
  3. 投稿を受信 — 一致する投稿をほぼリアルタイムで取得

エンドポイント


アクセスレベル

Enterprise のお問い合わせ

上限の引き上げと追加機能を利用
特定のティアが必要な演算子があります。embedding: セマンティック演算子は、Embedding ティアアクセスを持つ Enterprise プランでの Filtered Stream のみ で利用可能です。標準の従量課金アクセスには core 演算子のみが含まれます。

ルールの構築

ルールは検索クエリと同じ演算子を使用します:

ルール例

ルールを組み立てる

ルール構文と演算子を学ぶ

ストリームへの接続

永続 HTTP 接続を確立して投稿を受信します:

Keep-alive シグナル

ストリームは接続を維持するため、20 秒ごとに空行 (\r\n) を送信します。20 秒間データや keep-alive を受信しない場合は再接続してください。

切断の処理

グレースフルに再接続

ストリーミングデータの消費

投稿を効率的に処理

Webhook 配信

永続接続を維持する代わりに、Webhook 経由で投稿を受信できます:

Webhook 配信

Filtered stream の Webhook 配信を設定

投稿の編集

ストリームは編集された投稿を編集履歴と共に配信します。各編集は新しい投稿 ID を作成します:

Edit Posts の基礎

投稿の編集について詳しく学ぶ

はじめる

前提条件

クイックスタート

数分でストリームに接続

ルールを組み立てる

ルール構文を学ぶ

演算子リファレンス

すべての利用可能な演算子

サンプルコード

動作するコード例

高度なトピック

切断の処理

グレースフルに再接続

ハイボリューム容量

高スループットを処理

リカバリと冗長性

レジリエントなアプリを構築

返された投稿とのマッチング

どのルールが一致したかを識別