in cloud9/stream.py [0:0]
def set_rules(headers, bearer_token, rules):
if rules is None:
return
payload = {
'add': rules
}
response = requests.post(
"https://api.twitter.com/2/tweets/search/stream/rules",
headers=headers,
json=payload,
)
if response.status_code != 201:
raise Exception(
"Cannot add rules (HTTP {}): {}".format(response.status_code, response.text)
)