コンストラクター
constructor
client): StreamClient
パラメーター
| 名前 | type |
|---|---|
client | Client |
戻り値
StreamClient
定義場所
メソッド
likesCompliance
options?): Promise<EventDrivenStream>
Likes のコンプライアンスデータをストリーミングしますユーザーの Likes に関連するすべてのコンプライアンスデータをストリーミングします。 扱いやすいイベント駆動型ストリームを返します。
.on() を使用して ‘data’、‘error’、‘close’ などのイベントをリッスンします。
for await…of による非同期イテレーションにも対応しています。
パラメーター
| 名前 | type |
|---|---|
options | LikesComplianceStreamingOptions |
戻り値
Promise<EventDrivenStream>
ストリーミングデータを処理するためのイベント駆動ストリーム
定義場所
usersCompliance
partition, options?): Promise<EventDrivenStream>
ユーザーのコンプライアンスデータをストリーミングしますユーザーに関連するすべてのコンプライアンスデータをストリーミングします。 扱いやすいイベント駆動型ストリームを返します。
.on() を使って、‘data’、‘error’、‘close’ などのイベントをリッスンできます。for await...of 構文による非同期イテレーションにも対応しています。
パラメーター
| Name | Type | Description |
|---|---|---|
partition | number | パーティション番号。 |
options | UsersComplianceStreamingOptions | - |
戻り値
Promise<EventDrivenStream>
ストリーミングデータを処理するためのイベント駆動ストリーム
定義場所
postsFirehoseKo
partition, options?): Promise<EventDrivenStream>
韓国語の投稿をストリーミングします。
公開されている韓国語の投稿をリアルタイムにすべてストリーミングします。
扱いやすいイベント駆動ストリームを返します。
.on() を使って ‘data’、‘error’、‘close’ などのイベントをリッスンできます。
for await...of を用いた非同期イテレーションにも対応しています。
パラメーター
| Name | Type | Description |
|---|---|---|
partition | number | パーティション番号。 |
options | PostsFirehoseKoStreamingOptions | - |
戻り値
Promise<EventDrivenStream>
ストリーミングデータを扱うイベント駆動ストリーム
定義場所
likesSample10
partition, options?): Promise<EventDrivenStream>
いいねのサンプルをストリーミングします公開されているいいねの 10% サンプルをリアルタイムにストリーミングします。 使いやすいイベント駆動型ストリームを返します。
.on() を使って 'data'、'error'、'close' といったイベントをリッスンできます。for await...of を使った非同期反復処理にも対応しています。
パラメーター
| Name | Type | Description |
|---|---|---|
partition | number | パーティション番号。 |
options | LikesSample10StreamingOptions | - |
Returns
Promise<EventDrivenStream>
ストリーミングデータを扱うイベント駆動ストリーム
定義場所
likesFirehose
partition, options?): Promise<EventDrivenStream>
すべてのLikeのストリーム
すべての公開Likeをリアルタイムでストリーミングします。
使いやすいイベント駆動型ストリームを返します。
.on() を使用して、‘data’、‘error’、‘close’ などのイベントをリッスンできます。
for await...of を使った非同期イテレーションにも対応しています。
パラメーター
| Name | Type | Description |
|---|---|---|
partition | number | パーティション番号。 |
options | LikesFirehoseStreamingOptions | - |
戻り値
Promise<EventDrivenStream>
ストリーミングデータを処理するためのイベント駆動ストリーム
定義元
stream/stream_client.ts:1983postsFirehoseJa
partition, options?): Promise<EventDrivenStream>
日本語の投稿をストリーミングしますすべての公開された日本語の投稿をリアルタイムでストリーミングします。 使いやすいイベント駆動型ストリームを返します。
.on() を使って ‘data’、‘error’、‘close’ などのイベントをリッスンできます。
for await…of を使った非同期イテレーションにも対応しています。
パラメーター
| 名前 | 型 | 説明 |
|---|---|---|
partition | number | パーティション番号。 |
options | PostsFirehoseJaStreamingOptions | - |
戻り値
Promise<EventDrivenStream>
ストリーミングデータを処理するイベント駆動型ストリーム
定義元
stream/stream_client.ts:2257postsFirehoseEn
partition, options?): Promise<EventDrivenStream>
英語の投稿ストリーム
すべての公開されている英語の投稿をリアルタイムでストリーミングします。
使いやすいイベント駆動型ストリームを返します。
.on() を使って ‘data’、‘error’、‘close’ などのイベントをリッスンできます。
for await...of を使った非同期イテレーションにも対応しています。
パラメーター
| 名前 | 型 | 説明 |
|---|---|---|
partition | number | パーティション番号。 |
options | PostsFirehoseEnStreamingOptions | - |
戻り値
Promise<EventDrivenStream>
ストリーミングデータを処理するためのイベント駆動型ストリーム
定義場所
postsSample
options?): Promise<EventDrivenStream>
投稿サンプルのストリーム
公開投稿の 1% サンプルをリアルタイムでストリーミングします。
扱いやすいイベント駆動型ストリームを返します。
.on() を使って ‘data’、‘error’、‘close’ などのイベントを監視できます。
for await...of を用いた非同期イテレーションにも対応しています。
パラメーター
| 名前 | 型 |
|---|---|
options | PostsSampleStreamingOptions |
戻り値
Promise<EventDrivenStream>
ストリーミングデータを処理するためのイベント駆動型のストリーム
定義元
stream/stream_client.ts:2887postsSample10
partition, options?): Promise<EventDrivenStream>
10% サンプルの投稿をストリーミングします公開投稿の 10% サンプルをリアルタイムでストリーミングします。 使いやすいイベント駆動型ストリームを返します。
data、error、close といったイベントをリッスンするには .on() を使用します。for await...of による非同期イテレーションにも対応しています。
パラメーター
| Name | Type | Description |
|---|---|---|
partition | number | パーティション番号。 |
options | PostsSample10StreamingOptions | - |
戻り値
Promise<EventDrivenStream>
ストリーミングデータを処理するイベント駆動型のストリーム
定義場所
postsCompliance
partition, options?): Promise<EventDrivenStream>
投稿コンプライアンスデータをストリーミングします投稿に関連するすべてのコンプライアンスデータをストリーミングします。 使いやすいイベント駆動型ストリームを返します。
'data'、'error'、'close' などのイベントをリッスンするには .on() を使用します。また、
for await...of を使った非同期イテレーションにも対応しています。
パラメーター
| Name | Type | Description |
|---|---|---|
partition | number | パーティション番号。 |
options | PostsComplianceStreamingOptions | - |
戻り値
Promise<EventDrivenStream>
ストリーミングデータを扱うイベント駆動ストリーム
定義場所
labelsCompliance
options?): Promise<EventDrivenStream>
ポストのラベルをストリーミングします。
投稿に適用されるすべてのラベル付与イベントをストリーミングします。
使いやすいイベント駆動型ストリームを返します。
.on() を使用して、'data'、'error'、'close' などのイベントを監視できます。
for await...of による非同期イテレーションにも対応しています。
パラメーター
| 名前 | type |
|---|---|
options | LabelsComplianceStreamingOptions |
Returns
Promise<EventDrivenStream>
ストリーミングデータを処理するためのイベント駆動型のストリーム
定義場所
posts
options?): Promise<EventDrivenStream>
フィルターされた投稿をストリーミングしますアクティブなルールセットにマッチする投稿をリアルタイムでストリーミングします。 使いやすいイベント駆動型ストリームを返します。
'data'、'error'、'close' などのイベントを待ち受けるには .on() を使用します。for await...of を使った非同期イテレーションにも対応しています。
パラメーター
| 名前 | 型 |
|---|---|
options | PostsStreamingOptions |
戻り値
Promise<EventDrivenStream>
ストリーミングデータを処理するためのイベント駆動型のストリーム
定義場所
postsFirehose
partition, options?): Promise<EventDrivenStream>
すべての投稿をストリーミングしますすべての公開された投稿をリアルタイムでストリーミングします。 扱いやすいイベント駆動のストリームを返します。
'data'、'error'、'close' などのイベントを受信するには .on() を使用します。for await...of 構文による async イテレーションにも対応しています。
パラメーター
| Name | Type | Description |
|---|---|---|
partition | number | パーティション番号。 |
options | PostsFirehoseStreamingOptions | - |
戻り値
Promise<EventDrivenStream>
ストリーミングデータを扱うためのイベント駆動型ストリーム
定義元
stream/stream_client.ts:4125postsFirehosePt
partition, options?): Promise<EventDrivenStream>
ポルトガル語の投稿ストリームすべての公開ポルトガル語の投稿をリアルタイムでストリーミングします。 使いやすいイベント駆動型ストリームを返します。
.on() を使って、data、error、close などのイベントを監視できます。for await...of 構文を使った非同期イテレーションにも対応しています。
パラメーター
| 名称 | Type | 説明 |
|---|---|---|
partition | number | パーティション番号。 |
options | PostsFirehosePtStreamingOptions | - |
戻り値
Promise<EventDrivenStream>
ストリーミングデータを扱うイベント駆動型のストリーム
定義元
stream/stream_client.ts:4439getRuleCounts
options?): Promise<Get2TweetsSearchStreamRulesCountsResponse>
ストリームルール数を取得しますフィルタ済みストリームのアクティブなルールセット内にあるルール数を取得します。
パラメーター
| 名前 | 型 |
|---|---|
options | GetRuleCountsStreamingOptions |
戻り値
Promise<Get2TweetsSearchStreamRulesCountsResponse>
API レスポンスを返す Promise
定義場所
getRules
options?): Promise<RulesLookupResponse>
ストリームルールを取得しますフィルタ済みストリーム用の有効なルールセット全体、またはその一部を取得します。
パラメーター
| 名前 | 型 |
|---|---|
options | GetRulesStreamingOptions |
戻り値
Promise<RulesLookupResponse>
API レスポンスを返す Promise
定義場所
updateRules
body, options?): Promise<AddOrDeleteRulesResponse>
ストリームルールを更新しますフィルター済みストリームのアクティブなルールセットに対して、ルールを追加または削除します。
パラメータ
| 名前 | type |
|---|---|
body | any |
options | UpdateRulesStreamingOptions |
戻り値
Promise<AddOrDeleteRulesResponse>
API レスポンスを返す Promise