Как получить имя схемы вошедшего в систему арендатора в многопользовательском приложении Django?

Я использую sqlalchemy для получения результата запроса и затем передаю результат в кадр данных pandas. Но это введите описание изображения здесьвыдает ошибку типа "(psycopg2.errors.UndefinedTable) relation "identification_individual" does not exist".

Я выяснил, что для успешного выполнения этого оператора требуется имя схемы вместе с таблицей.

"schemaName.identification_individual" работает нормально

мой вопрос в том, как я могу получить имя схемы вошедшего в систему арендатора (я хочу, чтобы это было динамическим, чтобы схема менялась в соответствии с каждым арендатором) и как можно обновить приведенный ниже запрос.

кодом является:

   engine = sqlalchemy.create_engine('postgresql://postgres:password@localhost:5432/dbname')
   
    df= pd.read_sql_query("""SELECT DISTINCT (customer_id),customer_id,customer_type,product_type,delivery_channel,diligence_type,
                                            customer_name,over_all_discount_status,risk_score,risk_category,pep_status,identification_individual.city
                                            FROM identification_individual
                                            LEFT JOIN discounting_individuldiscount  ON identification_individual.customer_id = discounting_individuldiscount.individual_id
                                            WHERE over_all_discount_status='Pending' or over_all_discount_status='Rejected' or over_all_discount_status='Proceed';""",engine)
     
         

Вернуться на верх