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

类型错误： 无效的参数 'application_name' 发送到 create_engine((，使用配置 PGDialect_psycopg2/队列池/引擎。 请检查关键字 参数适用于此组件组合。

Answer 1

事实证明，正确的语法是

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

由于调用使SQLaChemy引擎看起来像

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

Answer 2

• PostgreSQL 数据库：

以下作品sqlalchemy==1.3.10

    # Establish database connection via sqlalchemy
    sqlalchemy_connection_kwargs = {'connect_args': {'application_name': 'herles_application'}}
    connection = create_engine(sqlalchemy_connection_string, **sqlalchemy_connection_kwargs)

如果您使用的是psycopg2-binary==2.8.4本机连接

native_connection = psycopg2.connect(user=cred['username'],
                                     password=cred['password'],
                                     host=cred['host'],
                                     port=cred['port'],
                                     database=cred['databaseName'],
                                     application_name="herles_application")