Ошибка при добавлении application_name в качестве параметра в dask.read_sql_table

Question

Я пытаюсь создать dask dataframe из таблицы в postgres. Я хотел бы передать application_name = 'myapp' в качестве стандарта для мониторинга и отслеживания активности БД.

Но когда я пытаюсь добавить параметр, я получаю ошибку ниже.

ddf = dd.read_sql_table('table', 
                        uri, 
                        schema='schema', 
                        index_col='index_col', 
                        engine_kwargs={'application_name':'myapp'})

TypeError: неверный аргумент (ы) 'application_name' отправлено create_engine (), используя конфигурацию PGDialect_psycopg2 / QueuePool / двигателя. Пожалуйста, проверьте, что ключевое слово аргументы подходят для этой комбинации компонентов.

Answer 1

Оказывается, правильный синтаксис был

ddf = dd.read_sql_table('table', 
                        uri, 
                        schema='schema', 
                        index_col='index_col', 
                        engine_kwargs={'connect_args': {'application_name': 'myapp'})

, поскольку вызов для создания механизма sqlalchemy выглядит как

engine = create_engine(uri, connect_kwargs={'application_name':' myapp'})