Powerstream low-latency streaming API on the X API v2

Powerstream is our lowest-latency streaming API for accessing public X data in real-time. Unlike other streaming endpoints that prioritize data hydration and delivery (with ~4-5 seconds P99 latency), Powerstream is optimized for speed and delivers data with minimal delay. Similar to the legacy GNIP Powertrack API, it uses rules to filter Posts based on keywords, operators, and metadata. Once a persistent HTTP connection is made to the Powerstream endpoint, you can start receiving matching Posts in real-time. Currently, Powerstream supports up to 1,000 rules and each rule can be 2048 characters.

Key features

Real-time data delivery: Lowest latency option for streaming Posts as they’re published.
Precise filtering: Filter for exactly the data you are looking for using Boolean queries with operators.
Delivery: JSON response over HTTP/1.1 chunked transfer encoding.
Local datacenter support: Fetch Posts only from the local datacenter to further reduce latency by avoiding replication lag.

The Powerstream API is a premium offering available under select Enterprise plans.If you’re interested in accessing Powerstream or learning more about our Enterprise offerings, please reach out to our Sales team by submitting the Enterprise Request Form. We’ll be happy to discuss how Powerstream can support your needs.

Quick start

This section showcases how to quickly get started with the PowerStream endpoints using Python with the requests library. Install it via pip install requests. All examples use OAuth 2.0 Bearer Token authentication. Replace YOUR_BEARER_TOKEN with your actual token (store it securely, e.g., via os.getenv('BEARER_TOKEN')). We’ll cover each endpoint with code snippets. Assume these imports at the top:

import requests
import json
import time
import sys
import os  # For env vars

Setup

bearer_token = os.getenv('BEARER_TOKEN') or "YOUR_BEARER_TOKEN"  # Use env var for security
base_url = "https://api.x.com/2/powerstream"
rules_url = f"{base_url}/rules"  # For rule management
headers = {
   "Authorization": f"Bearer {bearer_token}",
   "Content-Type": "application/json"
}

1. Create rules (POST /rules)

Add rules to filter your stream.

Example

data = {
   "rules": [
       {
           "value": "(cat OR dog) lang:en -is:retweet",
           "tag": "pet-monitor"
       },
       # Add more rules as needed (up to 100)
   ]
}

response = requests.post(rules_url, headers=headers, json=data)
if response.status_code == 201:
   rules_added = response.json().get("data", {}).get("rules", [])
   print("Rules added:")
   for rule in rules_added:
       print(f"ID: {rule['id']}, Value: {rule['value']}, Tag: {rule.get('tag', 'N/A')}")
else:
   print(f"Error {response.status_code}: {response.text}")

2. Delete rules (POST /rules)

Remove rules by ID (recommended) or value.

Example

data = {
   "rules": [
       {
           "value": "(cat OR dog) lang:en -is:retweet",
           "tag": "pet-monitor"
       },
       # Add more rules as needed (up to 100)
   ]
}

response = requests.delete(rules_url, headers=headers, json=data)
if response.status_code == 200:
   deleted = response.json().get("data", {})
   print(f"Deleted count: {deleted.get('deleted', 'N/A')}")
   if 'not_deleted' in deleted:
       print("Not deleted:", deleted['not_deleted'])
else:
   print(f"Error {response.status_code}: {response.text}")

Tip: To delete all rules, first GET them, extract IDs, then delete in bulk.

3. Get rules (GET /rules)

Fetch all active rules.

response = requests.get(rules_url, headers=headers)
if response.status_code == 200:
   rules = response.json().get("data", {}).get("rules", [])
   if rules:
       print("Active rules:")
       for rule in rules:
           print(f"ID: {rule['id']}, Value: {rule['value']}, Tag: {rule.get('tag', 'N/A')}")
   else:
       print("No active rules.")
else:
   print(f"Error {response.status_code}: {response.text}")

4. PowerStream (GET /stream)

Connect to the stream for real-time, low-latency Posts. Use stream=True for line-by-line reading. Implement reconnect logic for robustness.

Example

stream_url = base_url

def main():
   while True:
       response = requests.request("GET", stream_url, headers=headers, stream=True)
       print(response.status_code)
       for response_line in response.iter_lines():
           if response_line:
               json_response = json.loads(response_line)
               print(json.dumps(json_response, indent=4, sort_keys=True))
               if response.status_code != 200:
                   print(response.headers)
                   raise Exception(
                       "Request returned an error: {} {}".format(
                           response.status_code, response.text
                       )
                   )

Local datacenter support

For latency optimization, Powerstream provides an option to fetch only posts that originated or were created in the local datacenter where a connection is established. This avoids replication lag, resulting in faster delivery compared to posts from other datacenters. To enable this, append the query parameter ?localDcOnly=true to the stream endpoint (e.g., /2/powerstream?localDcOnly=true). The datacenter you are connected to will be indicated both in the initial data payload of the stream and as an HTTP header in the response. To use in code:

# For local datacenter only:
stream_url = "https://api.x.com/2/powerstream?localDcOnly=true"

If the localDcOnly parameter is enabled, when the stream first connects, it will include the following response headers indicating which local datacenter is being used:

'x-powerstream-datacenter': 'atla',
'x-powerstream-localdconly': 'true'

In addition to this, it will also send an initial payload specifying the datacenter:

{
    "type": "connection_metadata",
    "datacenter": "atla",
    "timestamp": 1762557264155
}

Tip: To optimize latency, set up connections from different geographic locations (e.g., one near Atlanta on the US East Coast and another near Portland on the US West Coast), enabling localDcOnly=true for each. This provides faster access to posts from each respective datacenter. Aggregate the streams on your end to combine cross-datacenter data.

Operators

In order to set rules for filtering, you can use keywords and operators.

Powerstream operators

Complete list of available operators

Responses

The payload of the Powerstream API is the same format as the legacy GNIP Powertrack API. A sample json response looks like:

Example response

[
   {
       "created_at": "Tue Mar 21 20:50:14 +0000 2006",
       "id": 20,
       "id_str": "20",
       "text": "just setting up my twttr",
       "truncated": false,
       "entities": {
           "hashtags": [],
           "symbols": [],
           "user_mentions": [],
           "urls": []
       },
       "source": "<a href=\"http://x.com\" rel=\"nofollow\">X Web Client</a>",
       "in_reply_to_status_id": null,
       "in_reply_to_status_id_str": null,
       "in_reply_to_user_id": null,
       "in_reply_to_user_id_str": null,
       "in_reply_to_screen_name": null,
       "user": {
           "id": 12,
           "id_str": "12",
           "name": "jack",
           "screen_name": "jack",
           "location": "",
           "description": "no state is the best state",
           "url": "https://t.co/ZEpOg6rn5L",
           "entities": {
               "url": {
                   "urls": [
                       {
                           "url": "https://t.co/ZEpOg6rn5L",
                           "expanded_url": "http://primal.net/jack",
                           "display_url": "primal.net/jack",
                           "indices": [
                               0,
                               23
                           ]
                       }
                   ]
               },
               "description": {
                   "urls": []
               }
           },
           "protected": false,
           "followers_count": 6427829,
           "friends_count": 3,
           "listed_count": 32968,
           "created_at": "Tue Mar 21 20:50:14 +0000 2006",
           "favourites_count": 36306,
           "utc_offset": null,
           "time_zone": null,
           "geo_enabled": true,
           "verified": false,
           "statuses_count": 30134,
           "lang": null,
           "contributors_enabled": false,
           "is_translator": false,
           "is_translation_enabled": false,
           "profile_background_color": "EBEBEB",
           "profile_background_image_url": "http://abs.twimg.com/images/themes/theme7/bg.gif",
           "profile_background_image_url_https": "https://abs.twimg.com/images/themes/theme7/bg.gif",
           "profile_background_tile": false,
           "profile_image_url": "http://pbs.twimg.com/profile_images/1661201415899951105/azNjKOSH_normal.jpg",
           "profile_image_url_https": "https://pbs.twimg.com/profile_images/1661201415899951105/azNjKOSH_normal.jpg",
           "profile_banner_url": "https://pbs.twimg.com/profile_banners/12/1742427520",
           "profile_link_color": "990000",
           "profile_sidebar_border_color": "DFDFDF",
           "profile_sidebar_fill_color": "F3F3F3",
           "profile_text_color": "333333",
           "profile_use_background_image": true,
           "has_extended_profile": true,
           "default_profile": false,
           "default_profile_image": false,
           "following": null,
           "follow_request_sent": null,
           "notifications": null,
           "translator_type": "regular",
           "withheld_in_countries": []
       },
       "geo": null,
       "coordinates": null,
       "place": null,
       "contributors": null,
       "is_quote_status": false,
       "retweet_count": 122086,
       "favorite_count": 263321,
       "favorited": false,
       "retweeted": false,
       "lang": "en"
   }
]

Edited posts

Each edit of a post creates a new post with a new ID, and Powerstream delivers every version that matches your rules. Posts that carry edit data include these fields at the top level of the post object:

Field	Type	Description
`edit_history.initial_tweet_id`	string	ID of the first post in the edit chain. For an original post, this is its own ID.
`edit_history.edit_tweet_ids`	array of strings	Every post ID in the edit chain, oldest first.
`edit_controls.editable_until_ms`	number	When the post can no longer be edited, in milliseconds since the Unix epoch.
`edit_controls.edits_remaining`	number	How many more times the post can be edited.
`editable`	boolean	Whether the post can be edited.

A post is an edit when edit_history.initial_tweet_id is different from its id_str. For example, the second version of an edited post looks like this:

Edited post (excerpt)

{
   "id_str": "1234567890123456790",
   "text": "Updated text",
   "edit_history": {
       "initial_tweet_id": "1234567890123456789",
       "edit_tweet_ids": [
           "1234567890123456789",
           "1234567890123456790"
       ]
   },
   "edit_controls": {
       "editable_until_ms": 1760040000000,
       "edits_remaining": 4
   },
   "editable": true
}

The first version of the same post has "initial_tweet_id": "1234567890123456789", the same as its own id_str. Reposts and quoted posts include their own edit fields inside retweeted_status and quoted_status. Some fields can be missing on individual posts; posts without edit data, such as posts created before editing was available, don’t include them. To receive only the first version of each post, add -is:edit to your rules. See Filtering out edited posts. For more on how editing works, see Edit Posts.

Limits and best practices

Rate Limits: 50 requests/24h for rule management; no limit on streams (but connection limits apply).
Reconnection: Exponential backoff on disconnects.
Monitoring: Use Connection: keep-alive headers.

Streaming fundamentals

Consuming streaming data

Best practices for streaming clients

Handling disconnections

Reconnect gracefully

High volume capacity

Handle high throughput

Recovery and redundancy

Build resilient applications

Analytics

Blocks

Volume Streams

Likes Streams

Powerstream

Account Activity

Filtered Stream Webhooks

Powerstream low-latency streaming API on the X API v2

Key features

Quick start

Setup

1. Create rules (POST /rules)

2. Delete rules (POST /rules)

3. Get rules (GET /rules)

4. PowerStream (GET /stream)

Local datacenter support

Operators

Powerstream operators

Responses

Edited posts

Limits and best practices

Streaming fundamentals

Consuming streaming data

Handling disconnections

High volume capacity

Recovery and redundancy

​Key features

​Quick start

​Setup

​1. Create rules (POST /rules)

​2. Delete rules (POST /rules)

​3. Get rules (GET /rules)

​4. PowerStream (GET /stream)

​Local datacenter support

​Operators

Powerstream operators

​Responses

​Edited posts

​Limits and best practices

​Streaming fundamentals

Consuming streaming data

Handling disconnections

High volume capacity

Recovery and redundancy

Key features

Quick start

Setup

1. Create rules (POST /rules)

2. Delete rules (POST /rules)

3. Get rules (GET /rules)

4. PowerStream (GET /stream)

Local datacenter support

Operators

Responses

Edited posts

Limits and best practices

Streaming fundamentals