python - 在 dask.read_sql_table 中添加 application_name 作为参数时出错

Question

我正在尝试从 postgres 中的表创建 dask 数据框。我想将 application_name = 'myapp' 作为标准传递用于监视和跟踪数据库事件。

但是当我尝试添加参数时，出现以下错误。

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

TypeError: Invalid argument(s) 'application_name' sent to create_engine(), using configuration PGDialect_psycopg2/QueuePool/Engine. Please check that the keyword arguments are appropriate for this combination of components.

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'})