Saltar al contenido principal

Constructores

constructor

new StreamClient(client): StreamClient

Parámetros

NombreType
clientClient

Devuelve

StreamClient

Definido en

stream/stream_client.ts:972

Métodos

likesCompliance

likesCompliance(options?): Promise<EventDrivenStream> Transmite datos de cumplimiento de Likes
Transmite todos los datos de cumplimiento relacionados con los Likes de los usuarios.
Devuelve un stream basado en eventos que es fácil de usar.
Usa .on() para escuchar eventos como data, error, close.
También admite iteración asíncrona con for await...of.

Parámetros

NombreTipo
optionsLikesComplianceStreamingOptions

Devuelve

Promise<EventDrivenStream> Flujo dirigido por eventos para procesar datos de streaming

Definido en

stream/stream_client.ts:1016

usersCompliance

usersCompliance(partition, options?): Promise<EventDrivenStream> Transmite datos de cumplimiento de usuarios
Transmite todos los datos de cumplimiento relacionados con usuarios.
Devuelve un flujo controlado por eventos que es fácil de usar.
Usa .on() para escuchar eventos como ‘data’, ‘error’, ‘close’.
También admite iteración asíncrona con for await…of.

Parámetros

NombreTipoDescripción
partitionnumberEl número de partición.
optionsUsersComplianceStreamingOptions-

Devuelve

Promise<EventDrivenStream> Flujo basado en eventos para gestionar datos de streaming

Definido en

stream/stream_client.ts:1196

postsFirehoseKo

postsFirehoseKo(partition, options?): Promise<EventDrivenStream> Transmitir Publicaciones en coreano Transmite en tiempo real todas las Publicaciones públicas en coreano. Devuelve un stream basado en eventos que es fácil de usar. Utiliza .on() para escuchar eventos como ‘data’, ‘error’, ‘close’. También admite iteración asíncrona con for await…of.

Parámetros

NombreTypeDescripción
partitionnumberEl número de partición.
optionsPostsFirehoseKoStreamingOptions-

Returns

Promise<EventDrivenStream> Flujo basado en eventos para procesar datos de streaming

Definido en

stream/stream_client.ts:1392

likesSample10

likesSample10(partition, options?): Promise<EventDrivenStream> Transmitir Likes muestreados Transmite en tiempo real una muestra del 10 % de los Likes públicos. Devuelve un stream basado en eventos que es fácil de usar. Usa .on() para escuchar eventos como ‘data’, ‘error’, ‘close’. También admite la iteración asíncrona con for await…of.

Parámetros

NombretypeDescripción
partitionnumberEl número de partición.
optionsLikesSample10StreamingOptions-

Returns

Promise<EventDrivenStream> Flujo basado en eventos para manejar datos en streaming

Definido en

stream/stream_client.ts:1706

likesFirehose

likesFirehose(partition, options?): Promise<EventDrivenStream> Flujo de todos los Likes Transmite en tiempo real todos los Likes públicos. Devuelve un stream basado en eventos que es fácil de usar. Utiliza .on() para escuchar eventos como ‘data’, ‘error’, ‘close’. También admite iteración asíncrona con for await…of.

Parámetros

NombreTypeDescripción
partitionnumberEl número de partición.
optionsLikesFirehoseStreamingOptions-

Devuelve

Promise<EventDrivenStream> Flujo basado en eventos para manejar datos en streaming

Definido en

stream/stream_client.ts:1983

postsFirehoseJa

postsFirehoseJa(partition, options?): Promise<EventDrivenStream> Flujo de Publicaciones en japonés Transmite en tiempo real todas las Publicaciones públicas en japonés. Devuelve un flujo controlado por eventos que es fácil de usar. Usa .on() para escuchar eventos como ‘data’, ‘error’, ‘close’. También admite la iteración asíncrona con for await…of.

Parámetros

NombreTipoDescripción
partitionnumberEl número de partición.
optionsPostsFirehoseJaStreamingOptions-

Devuelve

Promise<EventDrivenStream> Flujo basado en eventos para procesar datos en streaming

Definido en

stream/stream_client.ts:2257

postsFirehoseEn

postsFirehoseEn(partition, options?): Promise<EventDrivenStream> Flujo de Publicaciones en inglés Transmite en tiempo real todas las Publicaciones públicas en inglés. Devuelve un stream basado en eventos que es fácil de usar. Utiliza .on() para escuchar eventos como ‘data’, ‘error’, ‘close’. También admite iteración asíncrona con for await…of.

Parámetros

NombreTipoDescripción
partitionnumberEl número de partición.
optionsPostsFirehoseEnStreamingOptions-

Devuelve

Promise<EventDrivenStream> Stream controlado por eventos para procesar datos en streaming

Definido en

stream/stream_client.ts:2571

postsSample

postsSample(options?): Promise<EventDrivenStream> Transmitir Publicaciones muestreadas Transmite en tiempo real una muestra del 1 % de las Publicaciones públicas. Devuelve un stream basado en eventos que es fácil de usar. Usa .on() para escuchar eventos como ‘data’, ‘error’, ‘close’. También admite iteración asincrónica con for await…of.

Parámetros

NombreTipo
optionsPostsSampleStreamingOptions

Devuelve

Promise<EventDrivenStream> Flujo controlado por eventos para procesar datos de streaming

Definido en

stream/stream_client.ts:2887

postsSample10

postsSample10(partition, options?): Promise<EventDrivenStream> Stream de Publicaciones muestreadas al 10 % Transmite en tiempo real una muestra del 10 % de las Publicaciones públicas. Devuelve un stream basado en eventos que es fácil de usar. Utiliza .on() para escuchar eventos como ‘data’, ‘error’, ‘close’. También admite iteración asíncrona con for await…of.

Parámetros

NombreTipoDescripción
partitionnumberEl número de partición.
optionsPostsSample10StreamingOptions-

Devuelve

Promise<EventDrivenStream> Flujo basado en eventos para procesar datos en streaming

Definido en

stream/stream_client.ts:3145

postsCompliance

postsCompliance(partition, options?): Promise<EventDrivenStream> Transmitir datos de cumplimiento de Publicaciones
Transmite todos los datos de cumplimiento relacionados con Publicaciones.
Devuelve un stream basado en eventos que es fácil de usar.
Usa .on() para escuchar eventos como ‘data’, ‘error’, ‘close’.
También admite la iteración asíncrona con for await…of.

Parámetros

NombreTipoDescripción
partitionnumberEl número de partición.
optionsPostsComplianceStreamingOptions-

Devuelve

Promise<EventDrivenStream> Flujo controlado por eventos para procesar datos de streaming

Definido en

stream/stream_client.ts:3459

labelsCompliance

labelsCompliance(options?): Promise<EventDrivenStream> Transmite etiquetas de Publicaciones
Transmite todos los eventos de etiquetado aplicados a Publicaciones.
Devuelve un flujo basado en eventos que es fácil de usar.
Utiliza .on() para escuchar eventos como ‘data’, ‘error’, ‘close’.
También admite la iteración asíncrona con for await…of.

Parámetros

NombreType
optionsLabelsComplianceStreamingOptions

Returns

Promise<EventDrivenStream> Flujo controlado por eventos para procesar datos de streaming

Definido en

stream/stream_client.ts:3651

posts

posts(options?): Promise<EventDrivenStream> Stream de Publicaciones filtradas Transmite Publicaciones en tiempo real que coinciden con el conjunto de reglas activo. Devuelve un stream basado en eventos que es fácil de usar. Usa .on() para escuchar eventos como ‘data’, ‘error’, ‘close’. También admite iteración asíncrona con for await…of.

Parámetros

NombreTipo
optionsPostsStreamingOptions

Returns

Promise<EventDrivenStream> Flujo basado en eventos para procesar datos de streaming

Definido en

stream/stream_client.ts:3827

postsFirehose

postsFirehose(partition, options?): Promise<EventDrivenStream> Transmitir todas las Publicaciones Transmite todas las Publicaciones públicas en tiempo real. Devuelve un stream basado en eventos que es fácil de usar. Usa .on() para escuchar eventos como ‘data’, ‘error’, ‘close’. También admite la iteración asíncrona con for await…of.

Parámetros

NombretypeDescripción
partitionnumberEl número de partición.
optionsPostsFirehoseStreamingOptions-

Devuelve

Promise<EventDrivenStream> Flujo controlado por eventos para procesar datos de streaming

Definido en

stream/stream_client.ts:4125

postsFirehosePt

postsFirehosePt(partition, options?): Promise<EventDrivenStream> Transmisión de Publicaciones en portugués Transmite en tiempo real todas las Publicaciones públicas en portugués. Devuelve un flujo basado en eventos y fácil de usar. Usa .on() para escuchar eventos como ‘data’, ‘error’, ‘close’. También admite iteración asíncrona con for await…of.

Parámetros

NombreTipoDescripción
partitionnumberEl número de partición.
optionsPostsFirehosePtStreamingOptions-

Devuelve

Promise<EventDrivenStream> Flujo basado en eventos para manejar datos de streaming

Definido en

stream/stream_client.ts:4439

getRuleCounts

getRuleCounts(options?): Promise<Get2TweetsSearchStreamRulesCountsResponse> Obtener recuentos de reglas del stream Obtiene el número de reglas del conjunto de reglas activas para el stream filtrado.

Parámetros

NombreType
optionsGetRuleCountsStreamingOptions

Devuelve

Promise<Get2TweetsSearchStreamRulesCountsResponse> Promesa con la respuesta de la API

Definido en

stream/stream_client.ts:4753

getRules

getRules(options?): Promise<RulesLookupResponse> Obtener reglas del stream
Obtiene el conjunto de reglas activas o un subconjunto de reglas del stream filtrado.

Parámetros

NombreType
optionsGetRulesStreamingOptions

Devuelve

Promise<RulesLookupResponse> Promesa que contiene la respuesta de la API

Definido en

stream/stream_client.ts:4854

updateRules

updateRules(body, options?): Promise<AddOrDeleteRulesResponse> Actualiza las reglas del stream Agrega o elimina reglas del conjunto de reglas activas para el stream filtrado.

Parámetros

NombreType
bodyany
optionsUpdateRulesStreamingOptions

Devuelve

Promise<AddOrDeleteRulesResponse> Promesa que se resuelve con la respuesta de la API

Definido en

stream/stream_client.ts:4987