Passer au contenu principal

Constructeurs

constructeur

new StreamClient(client): StreamClient

Paramètres

NomType
clientClient

Renvoie

StreamClient

Défini dans

stream/stream_client.ts:972

Méthodes

likesCompliance

likesCompliance(options?): Promise<EventDrivenStream> Flux de données de conformité pour les Likes Diffuse toutes les données de conformité relatives aux Likes pour les utilisateurs. Renvoie un flux événementiel simple à utiliser. Utilisez .on() pour écouter des événements tels que ‘data’, ‘error’ et ‘close’. Prend également en charge l’itération asynchrone avec for await…of.

Paramètres

NomType
optionsLikesComplianceStreamingOptions

Renvoie

Promise<EventDrivenStream> Flux basé sur les événements pour traiter les données en streaming

Défini dans

stream/stream_client.ts:1016

usersCompliance

usersCompliance(partition, options?): Promise<EventDrivenStream> Diffuser les données de conformité des utilisateurs
Diffuse toutes les données de conformité liées aux utilisateurs.
Retourne un flux piloté par événements, facile à utiliser.
Utilisez .on() pour écouter des événements tels que ‘data’, ‘error’ ou ‘close’.
Prend également en charge l’itération asynchrone via for await…of.

Paramètres

NomTypeDescription
partitionnumberLe numéro de partition.
optionsUsersComplianceStreamingOptions-

Renvoie

Promise<EventDrivenStream> Flux événementiel pour gérer les données en streaming

Défini dans

stream/stream_client.ts:1196

postsFirehoseKo

postsFirehoseKo(partition, options?): Promise<EventDrivenStream> Flux de Publications en coréen Diffuse en temps réel toutes les Publications publiques en langue coréenne. Renvoie un flux piloté par les événements, simple à utiliser. Utilisez .on() pour écouter des événements comme ‘data’, ‘error’ ou ‘close’. Prend également en charge l’itération asynchrone avec for await…of.

Paramètres

NomTypeDescription
partitionnumberLe numéro de partition.
optionsPostsFirehoseKoStreamingOptions-

Retourne

Promise<EventDrivenStream> Flux piloté par événements pour traiter les données de streaming

Défini dans

stream/stream_client.ts:1392

likesSample10

likesSample10(partition, options?): Promise<EventDrivenStream> Flux d’échantillon de Likes
Diffuse un échantillon de 10 % des Likes publics en temps réel.
Retourne un flux événementiel, facile à utiliser. Utilisez .on() pour écouter des événements comme “data”, “error”, “close”. Prend également en charge l’itération asynchrone avec for await...of.

Paramètres

NomTypeDescription
partitionnumberLe numéro de partition.
optionsLikesSample10StreamingOptions-

Renvoie

Promise<EventDrivenStream> Flux événementiel pour traiter les données en streaming

Défini dans

stream/stream_client.ts:1706

likesFirehose

likesFirehose(partition, options?): Promise<EventDrivenStream> Flux de tous les Likes Diffuse tous les Likes publics en temps réel. Renvoie un flux piloté par les événements, facile à utiliser. Utilisez .on() pour écouter des événements comme ‘data’, ‘error’, ‘close’. Prend également en charge l’itération asynchrone avec for await…of.

Paramètres

NomTypeDescription
partitionnumberNuméro de partition.
optionsLikesFirehoseStreamingOptions-

Returns

Promise<EventDrivenStream> Flux événementiel pour traiter les données en streaming

Défini dans

stream/stream_client.ts:1983

postsFirehoseJa

postsFirehoseJa(partition, options?): Promise<EventDrivenStream> Flux de Publications en japonais Diffuse en temps réel toutes les Publications publiques en langue japonaise. Renvoie un flux piloté par événements, simple à utiliser. Utilisez .on() pour écouter des événements tels que ‘data’, ‘error’, ‘close’. Prend également en charge l’itération asynchrone avec for await…of.

Paramètres

NomTypeDescription
partitionnumberLe numéro de partition.
optionsPostsFirehoseJaStreamingOptions-

Returns

Promise<EventDrivenStream> Flux événementiel pour traiter des données en streaming

Défini dans

stream/stream_client.ts:2257

postsFirehoseEn

postsFirehoseEn(partition, options?): Promise<EventDrivenStream> Flux de publications en anglais
Diffuse en continu, en temps réel, toutes les publications publiques en anglais.
Retourne un flux orienté événements, simple à utiliser.
Utilisez .on() pour écouter des événements comme data, error, close.
Prend également en charge l’itération asynchrone avec for await...of.

Paramètres

NomTypeDescription
partitionnumberLe numéro de partition.
optionsPostsFirehoseEnStreamingOptions-

Renvoie

Promise<EventDrivenStream> Flux événementiel pour traiter des données en streaming

Défini dans

stream/stream_client.ts:2571

postsSample

postsSample(options?): Promise<EventDrivenStream> Diffuse un échantillon de Publications Diffuse en temps réel un échantillon de 1 % des Publications publiques. Renvoie un flux piloté par les événements, simple d’utilisation. Utilisez .on() pour écouter des événements tels que ‘data’, ‘error’ et ‘close’. Prend également en charge l’itération asynchrone avec for await…of.

Paramètres

NomType
optionsPostsSampleStreamingOptions

Renvoie

Promise<EventDrivenStream> Flux événementiel pour traiter les données en continu

Défini dans

stream/stream_client.ts:2887

postsSample10

postsSample10(partition, options?): Promise<EventDrivenStream> Diffuse un échantillon de 10 % de Publications Diffuse en temps réel un échantillon de 10 % des Publications publiques. Renvoie un flux piloté par les événements, simple à utiliser. Utilisez .on() pour écouter des événements tels que « data », « error », « close ». Prend également en charge l’itération asynchrone avec for await…of.

Paramètres

NomTypeDescription
partitionnumberLe numéro de partition.
optionsPostsSample10StreamingOptions-

Renvoie

Promise<EventDrivenStream> Flux orienté événements pour traiter des données en streaming

Défini dans

stream/stream_client.ts:3145

postsCompliance

postsCompliance(partition, options?): Promise<EventDrivenStream> Diffuse un flux de données de conformité des Publications Diffuse toutes les données de conformité liées aux Publications. Renvoie un flux basé sur les événements, facile à utiliser. Utilisez .on() pour écouter des événements tels que ‘data’, ‘error’ et ‘close’. Prend également en charge l’itération asynchrone via for await…of.

Paramètres

NomTypeDescription
partitionnumberLe numéro de partition.
optionsPostsComplianceStreamingOptions-

Returns

Promise<EventDrivenStream> Flux orienté événements pour gérer les données en streaming

Défini dans

stream/stream_client.ts:3459

labelsCompliance

labelsCompliance(options?): Promise<EventDrivenStream> Diffusion des labels de Publications
Diffuse tous les événements de labellisation appliqués aux Publications.
Renvoie un flux événementiel facile à utiliser.
Utilisez .on() pour écouter des événements tels que ‘data’, ‘error’, ‘close’.
Prend également en charge l’itération asynchrone avec for await…of.

Paramètres

NomType
optionsLabelsComplianceStreamingOptions

Renvoie

Promise<EventDrivenStream> Flux événementiel pour gérer les données en streaming

Défini dans

stream/stream_client.ts:3651

posts

posts(options?): Promise<EventDrivenStream> Diffuse un flux de Publications filtrées Diffuse en temps réel les Publications correspondant à l’ensemble de règles actif. Renvoie un flux orienté événements, simple à utiliser. Utilisez .on() pour écouter des événements tels que ‘data’, ‘error’ ou ‘close’. Prend également en charge l’itération asynchrone avec for await…of.

Paramètres

NomType
optionsPostsStreamingOptions

Valeur de retour

Promise<EventDrivenStream> Flux basé sur les événements pour gérer les données en streaming

Défini dans

stream/stream_client.ts:3827

postsFirehose

postsFirehose(partition, options?): Promise<EventDrivenStream> Diffuser toutes les Publications Diffuse toutes les Publications publiques en temps réel. Retourne un flux piloté par des événements, facile à utiliser. Utilisez .on() pour écouter des événements comme ‘data’, ‘error’ ou ‘close’. Prend également en charge l’itération asynchrone avec for await…of.

Paramètres

NomTypeDescription
partitionnumberLe numéro de partition.
optionsPostsFirehoseStreamingOptions-

Retourne

Promise<EventDrivenStream> Flux événementiel pour traiter les données de streaming

Défini dans

stream/stream_client.ts:4125

postsFirehosePt

postsFirehosePt(partition, options?): Promise<EventDrivenStream> Flux de publications en portugais Diffuse en continu toutes les publications publiques en portugais en temps réel. Renvoie un flux basé sur les événements, simple à utiliser. Utilisez .on() pour écouter des événements tels que ‘data’, ‘error’, ‘close’. Prend également en charge l’itération asynchrone avec for await…of.

Paramètres

NomTypeDescription
partitionnumberLe numéro de partition.
optionsPostsFirehosePtStreamingOptions-

Returns

Promise<EventDrivenStream> Flux piloté par événements pour traiter les données en streaming

Défini dans

stream/stream_client.ts:4439

getRuleCounts

getRuleCounts(options?): Promise<Get2TweetsSearchStreamRulesCountsResponse> Obtenir le nombre de règles du flux
Renvoie le nombre de règles dans l’ensemble de règles actif pour le flux filtré.

Paramètres

NomType
optionsGetRuleCountsStreamingOptions

Renvoie

Promise<Get2TweetsSearchStreamRulesCountsResponse> Promise résolue avec la réponse de l’API

Défini dans

stream/stream_client.ts:4753

getRules

getRules(options?): Promise<RulesLookupResponse> Obtenir les règles du flux Récupère le jeu de règles actif ou un sous-ensemble de règles pour le flux filtré.

Paramètres

NomType
optionsGetRulesStreamingOptions

Renvoie

Promise<RulesLookupResponse> Promise contenant la réponse de l’API

Défini dans

stream/stream_client.ts:4854

updateRules

updateRules(body, options?): Promise<AddOrDeleteRulesResponse> Met à jour les règles du flux Ajoute ou supprime des règles du jeu de règles actif pour le flux filtré.

Paramètres

NomType
bodyany
optionsUpdateRulesStreamingOptions

Renvoie

Promise<AddOrDeleteRulesResponse> Promise renvoyant la réponse de l’API

Défini dans

stream/stream_client.ts:4987