Constructeurs
constructeur
client): StreamClient
Paramètres
| Nom | Type |
|---|---|
client | Client |
Renvoie
StreamClient
Défini dans
Méthodes
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
| Nom | Type |
|---|---|
options | LikesComplianceStreamingOptions |
Renvoie
Promise<EventDrivenStream>
Flux basé sur les événements pour traiter les données en streaming
Défini dans
usersCompliance
partition, options?): Promise<EventDrivenStream>
Diffuser les données de conformité des utilisateursDiffuse 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
| Nom | Type | Description |
|---|---|---|
partition | number | Le numéro de partition. |
options | UsersComplianceStreamingOptions | - |
Renvoie
Promise<EventDrivenStream>
Flux événementiel pour gérer les données en streaming
Défini dans
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
| Nom | Type | Description |
|---|---|---|
partition | number | Le numéro de partition. |
options | PostsFirehoseKoStreamingOptions | - |
Retourne
Promise<EventDrivenStream>
Flux piloté par événements pour traiter les données de streaming
Défini dans
likesSample10
partition, options?): Promise<EventDrivenStream>
Flux d’échantillon de LikesDiffuse 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
| Nom | Type | Description |
|---|---|---|
partition | number | Le numéro de partition. |
options | LikesSample10StreamingOptions | - |
Renvoie
Promise<EventDrivenStream>
Flux événementiel pour traiter les données en streaming
Défini dans
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
| Nom | Type | Description |
|---|---|---|
partition | number | Numéro de partition. |
options | LikesFirehoseStreamingOptions | - |
Returns
Promise<EventDrivenStream>
Flux événementiel pour traiter les données en streaming
Défini dans
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
| Nom | Type | Description |
|---|---|---|
partition | number | Le numéro de partition. |
options | PostsFirehoseJaStreamingOptions | - |
Returns
Promise<EventDrivenStream>
Flux événementiel pour traiter des données en streaming
Défini dans
postsFirehoseEn
partition, options?): Promise<EventDrivenStream>
Flux de publications en anglaisDiffuse 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
| Nom | Type | Description |
|---|---|---|
partition | number | Le numéro de partition. |
options | PostsFirehoseEnStreamingOptions | - |
Renvoie
Promise<EventDrivenStream>
Flux événementiel pour traiter des données en streaming
Défini dans
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
| Nom | Type |
|---|---|
options | PostsSampleStreamingOptions |
Renvoie
Promise<EventDrivenStream>
Flux événementiel pour traiter les données en continu
Défini dans
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
| Nom | Type | Description |
|---|---|---|
partition | number | Le numéro de partition. |
options | PostsSample10StreamingOptions | - |
Renvoie
Promise<EventDrivenStream>
Flux orienté événements pour traiter des données en streaming
Défini dans
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
| Nom | Type | Description |
|---|---|---|
partition | number | Le numéro de partition. |
options | PostsComplianceStreamingOptions | - |
Returns
Promise<EventDrivenStream>
Flux orienté événements pour gérer les données en streaming
Défini dans
labelsCompliance
options?): Promise<EventDrivenStream>
Diffusion des labels de PublicationsDiffuse 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
| Nom | Type |
|---|---|
options | LabelsComplianceStreamingOptions |
Renvoie
Promise<EventDrivenStream>
Flux événementiel pour gérer les données en streaming
Défini dans
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
| Nom | Type |
|---|---|
options | PostsStreamingOptions |
Valeur de retour
Promise<EventDrivenStream>
Flux basé sur les événements pour gérer les données en streaming
Défini dans
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
| Nom | Type | Description |
|---|---|---|
partition | number | Le numéro de partition. |
options | PostsFirehoseStreamingOptions | - |
Retourne
Promise<EventDrivenStream>
Flux événementiel pour traiter les données de streaming
Défini dans
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
| Nom | Type | Description |
|---|---|---|
partition | number | Le numéro de partition. |
options | PostsFirehosePtStreamingOptions | - |
Returns
Promise<EventDrivenStream>
Flux piloté par événements pour traiter les données en streaming
Défini dans
getRuleCounts
options?): Promise<Get2TweetsSearchStreamRulesCountsResponse>
Obtenir le nombre de règles du fluxRenvoie le nombre de règles dans l’ensemble de règles actif pour le flux filtré.
Paramètres
| Nom | Type |
|---|---|
options | GetRuleCountsStreamingOptions |
Renvoie
Promise<Get2TweetsSearchStreamRulesCountsResponse>
Promise résolue avec la réponse de l’API
Défini dans
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
| Nom | Type |
|---|---|
options | GetRulesStreamingOptions |
Renvoie
Promise<RulesLookupResponse>
Promise contenant la réponse de l’API
Défini dans
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
| Nom | Type |
|---|---|
body | any |
options | UpdateRulesStreamingOptions |
Renvoie
Promise<AddOrDeleteRulesResponse>
Promise renvoyant la réponse de l’API