Need Help with sending data from python to Supabase.

[ssara05]

I am having trouble getting my code to work, i am getting and this error:

Authentication successful!
Failed to send data to Supabase: Client error '401 Unauthorized' for url 'https://<my_url>.supabase.co/rest/v1/test_location'
For more information check: https://httpstatuses.com/401
Live Count: 0

I am trying get get data from a local program that is sending data to a JSON URL and then send that data to supabase with RLS on. With RLS off I can send data but that is not secure.
If anyone could help that would be appreciated.

This is my code:

import httpx
import requests
from datetime import datetime, timezone
import time
from supabase import Client, create_client

SUPABASE_URL = "hidden"
SUPABASE_API_KEY = "hidden"


def authenticate_user(email, password):
    user_data = client.auth.sign_in_with_password(
        {"email": email, "password": password}
        )
    user_id = user_data.user.id

    headers = {
        "Content-Type": "application/json",
        "apikey": SUPABASE_API_KEY,
    }

    data = {
        "email": email,
        "password": password,
    }

        session = user_data.session
        client.postgrest.auth(token=session.access_token)
        access_token = session.access_token
        print (access_token)
        return access_token



# Function to fetch data from the JSON web URL
def fetch_data(url):
    try:
        response = requests.get(url)
        response.raise_for_status()
        return response.json()
    except requests.RequestException as e:
        print(f"Failed to fetch data: {e}")
        return None

# Function to calculate live count
def calculate_live_count(data):
    enter_count = sum(1 for entry in data if entry['rule_name'] == 'Enter')
    exit_count = sum(1 for entry in data if entry['rule_name'] == 'Exit')
    return enter_count - exit_count

# Function to send data to Supabase
def send_data_to_supabase(access_token, data):

        
    # Create the Supabase client with the headers
    client = create_client(SUPABASE_URL, SUPABASE_API_KEY)
    table_name = 'test_location'
    timestamp_with_timezone = datetime.now(timezone.utc)
    formatted_timestamp = timestamp_with_timezone.isoformat()

    # Format coordinates as a JSON string (lat, long)
    formatted_coordinates = data['coordinates']
    
    # Create a new row with the provided data
    data_to_insert = {
        'name': data['name'],
        'coordinates': formatted_coordinates,
        'timestamp': formatted_timestamp,
        'live_count': data['live_count']
    }
    
    # Set the Authorization header with the access token
    headers = {
        'Authorization': f'Bearer {access_token}'
    }
    
    try:
        url = f"{SUPABASE_URL}/rest/v1/{table_name}"
        response = httpx.post(url, json=[data_to_insert], headers=headers)
        response.raise_for_status()
        print("Data sent to Supabase successfully.")
        return client
    except Exception as e:
        print(f"Failed to send data to Supabase: {e}")
        return client

if __name__ == "__main__":
    print("Supabase User Authentication")

    email = input("Enter your email: ")
    password = input("Enter your password: ")

    access_token = authenticate_user(email, password)

    if access_token:
        print("Authentication successful!")
        
        # Fetch and send data to Supabase
        json_url1 = 'http://localhost:48462/v1/json/events?limit=10&order=DESC&timeout=5'
        supabase_url1 = SUPABASE_URL
        supabase_key1 = SUPABASE_API_KEY
        
        while True:
            fetched_data = fetch_data(json_url1)

            if fetched_data:
                live_count = calculate_live_count(fetched_data)
                # Get other variables: name, coordinates, timestamp

                # Send data to Supabase
                send_data_to_supabase(access_token, {
                    'name': 'YourName',
                    'coordinates': 'YourCoordinates',
                    'timestamp': int(time.time()),
                    'live_count': live_count
                })
                print(f"Live Count: {live_count}")

            time.sleep(10)  # Wait for 10 seconds before the next update
    else:
        print("Authentication failed. Please check your credentials.")

[GaryAustin1]

What is your insert and select RLS?

[ssara05]

Dont worry i fixed it. I had to change permision for all actions In RLS