यह मॉड्यूल X API के activity endpoints के साथ इंटरैक्ट करने के लिए एक client उपलब्ध कराता है।
रियल-टाइम स्ट्रीमिंग ऑपरेशन ऐसे generators लौटाते हैं, जो डेटा आते ही उसे प्रदान करते हैं।
बेहतर विश्वसनीयता के लिए, स्ट्रीमिंग कनेक्शनों को exponential backoff retry logic के साथ अपने-आप प्रबंधित किया जाता है।
क्लास
बेस: object
गतिविधि ऑपरेशनों हेतु स्ट्रीमिंग Client
X गतिविधि सदस्यता बनाएँ
X गतिविधि इवेंट के लिए एक सदस्यता बनाता है।
body: अनुरोध बॉडी
:returns: रिस्पॉन्स डेटा
:rtype: CreateSubscriptionResponse
body.body
CreateSubscriptionRequest
X गतिविधि सदस्यता हटाता है
X गतिविधि इवेंट के लिए सदस्यता हटाता है
हटाई जाने वाली सदस्यता की ID।
DeleteSubscriptionResponse - रिस्पॉन्स डेटा
X गतिविधि सदस्यताएँ प्राप्त करें
XAA के लिए सक्रिय सदस्यताओं की सूची प्राप्त करें
:returns: रिस्पॉन्स डेटा
:rtype: GetSubscriptionsResponse
GetSubscriptionsResponse
एक्टिविटी स्ट्रीम (Streaming)
X गतिविधियों की स्ट्रीम
यह एक स्ट्रीमिंग endpoint है, जो डेटा उपलब्ध होते ही उसे रीयल-टाइम में प्रदान करता है।
स्ट्रीम से प्राप्त प्रत्येक आइटम एक एकल डेटा बिंदु का प्रतिनिधित्व करता है।
कनेक्शन को exponential backoff retry logic के साथ अपने-आप प्रबंधित किया जाता है।
यदि स्ट्रीम डिस्कनेक्ट हो जाती है, तो SDK क्लाइंट के हस्तक्षेप के बिना अपने-आप फिर से कनेक्ट हो जाएगा।
path.backfill_minutes
int or None
डिफ़ॉल्ट:"None"
अनुरोधित बैकफिल की मिनटों में संख्या।
path.start_time
str or None
डिफ़ॉल्ट:"None"
YYYY-MM-DDTHH:mm:ssZ. वह सबसे शुरुआती UTC टाइमस्टैम्प, जिससे पोस्ट लेबल उपलब्ध कराए जाएंगे।
path.end_time
str or None
डिफ़ॉल्ट:"None"
YYYY-MM-DDTHH:mm:ssZ. वह नवीनतम UTC टाइमस्टैम्प, जिससे पोस्ट लेबल उपलब्ध कराए जाएंगे।
रीट्राई व्यवहार, टाइमआउट और कॉलबैक को अनुकूलित करने के लिए वैकल्पिक StreamConfig।
X गतिविधि सदस्यता को अपडेट करें
X गतिविधि इवेंट के लिए किसी सदस्यता को अपडेट करता है
अपडेट की जाने वाली सदस्यता की ID.
body.body
UpdateSubscriptionRequest
अनुरोध बॉडी