त्वरित शुरुआत

यह मार्गदर्शिका आपको फ़िल्टर की गई स्ट्रीम से जुड़कर अपने फ़िल्टर नियमों से मेल खाने वाली रीयल-टाइम पोस्ट्स प्राप्त करने का तरीका बताती है।

पूर्वापेक्षाएँशुरू करने से पहले, आपको इनकी आवश्यकता होगी:

एक डेवलपर खाता
आपके ऐप का बेयरर टोकन (जो डेवलपर कंसोल में “Keys and tokens” के अंतर्गत मिलता है)

फ़िल्टर नियम बनाएँ

नियम यह निर्धारित करते हैं कि कौन-से पोस्ट्स प्राप्त किए जाएँ। कीवर्ड, हैशटैग, उपयोगकर्ताओं आदि के आधार पर मिलान करने के लिए ऑपरेटर्स का उपयोग करें।उदाहरण नियम: images वाले “cat” युक्त पोस्ट्स का मिलान करें:

cat has:images

एक नियम बनाएँ

नियमों के सिंटैक्स और ऑपरेटरों के बारे में जानें

अपनी स्ट्रीम में नियम जोड़ें

rules एंडपॉइंट का उपयोग करके अपना नियम जोड़ें। यह पहचानने के लिए tag शामिल करें कि प्रत्येक पोस्ट किस नियम से मेल खाती है:

cURL

curl -X POST "https://api.x.com/2/tweets/search/stream/rules" \
  -H "Authorization: Bearer $BEARER_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "add": [
      {"value": "cat has:images", "tag": "cats with images"}
    ]
  }'

from xdk import Client

client = Client(bearer_token="YOUR_BEARER_TOKEN")

# फ़िल्टर की गई स्ट्रीम में एक नियम जोड़ें
response = client.filtered_stream.add_rules(
    add=[{"value": "cat has:images", "tag": "cats with images"}]
)

for rule in response.data:
    print(f"Rule added: {rule.id} - {rule.value}")

import { Client } from "@xdevplatform/xdk";

const client = new Client({ bearerToken: "YOUR_BEARER_TOKEN" });

// फ़िल्टर की गई स्ट्रीम में एक नियम जोड़ें
const response = await client.filteredStream.addRules({
  add: [{ value: "cat has:images", tag: "cats with images" }],
});

response.data?.forEach((rule) => {
  console.log(`Rule added: ${rule.id} - ${rule.value}`);
});

रिस्पॉन्स:

{
  "data": [
    {
      "id": "1273026480692322304",
      "value": "cat has:images",
      "tag": "cats with images"
    }
  ],
  "meta": {
    "sent": "2024-01-15T10:30:00.000Z",
    "summary": {
      "created": 1,
      "not_created": 0,
      "valid": 1,
      "invalid": 0
    }
  }
}

अपने नियम सत्यापित करें

यह पुष्टि करने के लिए कि आपका नियम जोड़ा गया है, सभी सक्रिय नियमों की सूची देखें:

cURL

curl "https://api.x.com/2/tweets/search/stream/rules" \
  -H "Authorization: Bearer $BEARER_TOKEN"

from xdk import Client

client = Client(bearer_token="YOUR_BEARER_TOKEN")

# सभी सक्रिय नियम प्राप्त करें
response = client.filtered_stream.get_rules()

for rule in response.data:
    print(f"Active rule: {rule.id} - {rule.value}")

import { Client } from "@xdevplatform/xdk";

const client = new Client({ bearerToken: "YOUR_BEARER_TOKEN" });

// सभी सक्रिय नियम प्राप्त करें
const response = await client.filteredStream.getRules();

response.data?.forEach((rule) => {
  console.log(`Active rule: ${rule.id} - ${rule.value}`);
});

स्ट्रीम से जुड़ें

मेल खाने वाले पोस्ट्स प्राप्त करने के लिए एक स्थायी कनेक्शन खोलें:

cURL

curl "https://api.x.com/2/tweets/search/stream?\
tweet.fields=created_at,author_id&\
expansions=author_id&\
user.fields=username" \
  -H "Authorization: Bearer $BEARER_TOKEN"

from xdk import Client

client = Client(bearer_token="YOUR_BEARER_TOKEN")

# फ़िल्टर की गई स्ट्रीम से कनेक्ट करें
for post in client.filtered_stream.stream(
    tweet_fields=["created_at", "author_id"],
    expansions=["author_id"],
    user_fields=["username"]
):
    print(f"New post: {post.data.text}")
    print(f"Matching rules: {post.matching_rules}")

import { Client } from "@xdevplatform/xdk";

const client = new Client({ bearerToken: "YOUR_BEARER_TOKEN" });

// फ़िल्टर की गई स्ट्रीम से कनेक्ट करें
const stream = client.filteredStream.stream({
  tweetFields: ["created_at", "author_id"],
  expansions: ["author_id"],
  userFields: ["username"],
});

for await (const post of stream) {
  console.log(`New post: ${post.data?.text}`);
  console.log(`Matching rules: ${post.matching_rules}`);
}

आने वाली पोस्ट्स को प्रोसेस करें

मेल खाने वाले पोस्ट्स, JSON ऑब्जेक्ट्स के रूप में स्ट्रीम किए जाते हैं:

{
  "data": {
    "id": "1234567890",
    "text": "Look at this cute cat! 🐱",
    "author_id": "9876543210",
    "created_at": "2024-01-15T10:35:00.000Z",
    "edit_history_tweet_ids": ["1234567890"]
  },
  "includes": {
    "users": [
      {
        "id": "9876543210",
        "username": "catperson"
      }
    ]
  },
  "matching_rules": [
    {
      "id": "1273026480692322304",
      "tag": "cats with images"
    }
  ]
}

matching_rules array यह दिखाती है कि आपके द्वारा परिभाषित टै्स का उपयोग करके कौन-से नियम पोस्ट से मेल खाते हैं।

नियम हटाएँ (वैकल्पिक)

ID के आधार पर नियम हटाएँ:

cURL

curl -X POST "https://api.x.com/2/tweets/search/stream/rules" \
  -H "Authorization: Bearer $BEARER_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "delete": {
      "ids": ["1273026480692322304"]
    }
  }'

from xdk import Client

client = Client(bearer_token="YOUR_BEARER_TOKEN")

# ID के आधार पर नियम हटाएँ
response = client.filtered_stream.delete_rules(
    delete={"ids": ["1273026480692322304"]}
)
print(f"Deleted: {response.meta.summary.deleted}")

import { Client } from "@xdevplatform/xdk";

const client = new Client({ bearerToken: "YOUR_BEARER_TOKEN" });

// ID के आधार पर नियम हटाएँ
const response = await client.filteredStream.deleteRules({
  delete: { ids: ["1273026480692322304"] },
});
console.log(`Deleted: ${response.meta?.summary?.deleted}`);

अपने कनेक्शन को प्रबंधित करना

कीप-अलाइव सिग्नल

स्ट्रीम हर 20 सेकंड में खाली पंक्तियाँ (\r\n) भेजती है। अगर आपको 20 सेकंड तक न डेटा मिले और न ही कोई कीप-अलाइव, तो फिर से कनेक्ट करें।

डिस्कनेक्ट करना

कनेक्शन बंद करने के लिए Ctrl+C दबाएँ या अपनी टर्मिनल विंडो बंद करें।

कनेक्शन सीमाएँ

प्रति ऐप केवल एक कनेक्शन की अनुमति है। नया कनेक्शन खोलने पर कोई भी मौजूदा कनेक्शन बंद हो जाएगा।

अगले चरण

एक नियम बनाएँ

नियम का सिंटैक्स जानें

ऑपरेटर संदर्भ

सभी उपलब्ध ऑपरेटर

डिस्कनेक्शन को संभालना

सहज रूप से फिर से कनेक्ट करें

API संदर्भ

एंडपॉइंट का पूरा दस्तावेज़ीकरण

अवलोकन

पोस्ट्स

उपयोगकर्ता

डायरेक्ट मैसेज

लाइक्स

सूचियाँ

Spaces

Communities

Community Notes

ट्रेंड्स

समाचार

मीडिया

X गतिविधि

उपयोग

स्ट्रीम कनेक्शन

अनुपालन

Enterprise v2

लाइक्स स्ट्रीम्स

GNIP 2.0

त्वरित शुरुआत

एक नियम बनाएँ

अपने कनेक्शन को प्रबंधित करना

अगले चरण

एक नियम बनाएँ

ऑपरेटर संदर्भ

डिस्कनेक्शन को संभालना

API संदर्भ

एक नियम बनाएँ

​अपने कनेक्शन को प्रबंधित करना

​अगले चरण

एक नियम बनाएँ

ऑपरेटर संदर्भ

डिस्कनेक्शन को संभालना

API संदर्भ

अपने कनेक्शन को प्रबंधित करना

अगले चरण