Exception: (401, '{\n "title": "Unauthorized",\n

Olá pessoal, estou tendo o erro 401 ao conectar a API do twitter. Já tentei procurar em vários lugares e não encontrei uma solução. Olhei também as discussões antigas aqui do fórum mas nenhuma me ajudou. Será que alguém conseguiria me ajudar?

401
Traceback (most recent call last):
  File "recent_search.py", line 57, in <module>
    main()
  File "recent_search.py", line 53, in main
    for json_response in paginate(url, headers):
  File "recent_search.py", line 44, in paginate
    data = connect_to_endpoint(full_url, headers)
  File "recent_search.py", line 36, in connect_to_endpoint
    raise Exception(response.status_code, response.text)
Exception: (401, '{\n  "title": "Unauthorized",\n  "type": "about:blank",\n  "status": 401,\n  "detail": "Unauthorized"\n}')

Segue abaixo o meu código.

import requests
import os
import json

# To set your enviornment variables in your terminal run the following line:
# export 'BEARER_TOKEN'='<your_bearer_token>'

def auth():
    return os.environ.get("BEARER_TOKEN")

def create_url():
    query = "AluraOnline"
    # Tweet fields are adjustable.
    # Options include:
    # attachments, author_id, context_annotations,
    # conversation_id, created_at, entities, geo, id,
    # in_reply_to_user_id, lang, non_public_metrics, organic_metrics,
    # possibly_sensitive, promoted_metrics, public_metrics, referenced_tweets,
    # source, text, and withheld
    tweet_fields = "tweet.fields=author_id,conversation_id,created_at,id,in_reply_to_user_id,public_metrics,text"
    user_fields = "expansions=author_id&user.fields=id,name,username,created_at"
    filters = "start_time=2022-02-28T00:00:00.000Z&end_time=2022-03-05T00:00:00.000Z"
    url = "https://api.twitter.com/2/tweets/search/recent?query={}&{}&{}&{}".format(
        query, tweet_fields, user_fields, filters
    )
    return url

def create_headers(bearer_token):
    headers = {"Authorization": "Bearer {}".format(bearer_token)}
    return headers

def connect_to_endpoint(url, headers):
    response = requests.request("GET", url, headers=headers)
    print(response.status_code)
    if response.status_code != 200:
        raise Exception(response.status_code, response.text)
    return response.json()

def paginate(url, headers, next_token=""):
    if next_token:
        full_url = f"{url}&next_token={next_token}"
    else:
        full_url = url
    data = connect_to_endpoint(full_url, headers)
    yield data
    if "next_token" in data.get("meta", {}):
        yield from paginate(url, headers, data["meta"]["next_token"])

def main():
    bearer_token = auth()
    url = create_url()
    headers = create_headers(bearer_token)
    for json_response in paginate(url, headers):
        print(json.dumps(json_response, indent=4, sort_keys=True))

if __name__ == "__main__":
    main()