SQL Alchemy :无法使用engine.connect()进行连接
SQLAlchemy是一个Python的SQL工具包和对象关系映射（ORM）库。它提供了一组高级的API，使得在Python中操作关系型数据库变得更加简单和灵活。
SQLAlchemy的主要特点包括：
- ORM支持：SQLAlchemy提供了ORM功能，可以将数据库表映射为Python类，通过操作这些类来进行数据库的增删改查操作，使得开发者可以使用面向对象的方式来操作数据库，提高了开发效率和代码的可读性。
- 多数据库支持：SQLAlchemy支持多种数据库后端，包括MySQL、PostgreSQL、SQLite、Oracle等，可以通过简单的配置切换不同的数据库，而不需要修改大量的代码。
- 强大的查询功能：SQLAlchemy提供了丰富的查询API，可以灵活地构建复杂的查询条件，支持多表关联查询、聚合函数、子查询等高级查询操作。
- 事务支持：SQLAlchemy提供了事务管理的功能，可以确保数据库操作的原子性和一致性，保证数据的完整性。
- 数据库连接池：SQLAlchemy内置了连接池，可以有效地管理数据库连接，提高数据库的访问性能。
- 支持原生SQL：除了ORM功能外，SQLAlchemy还提供了原生SQL的支持，可以直接执行SQL语句，满足一些特殊需求。
SQLAlchemy适用于各种规模的应用程序，特别是对于需要频繁进行数据库操作的应用程序，它可以简化数据库操作的代码，提高开发效率。
对于无法使用engine.connect()进行连接的问题，可能是由于以下原因：
- 数据库连接配置错误：请确保在创建
engine对象时，传入了正确的数据库连接参数，包括数据库类型、主机地址、端口号、用户名、密码等。 - 数据库服务未启动：请确保数据库服务已经启动，并且可以通过网络访问。
- 防火墙或网络访问限制：请确保防火墙或网络访问控制列表（ACL）没有限制对数据库的访问。
- 数据库权限不足：请确保使用的数据库用户具有足够的权限来连接和操作数据库。
针对这个问题，腾讯云提供了一系列的云数据库产品，包括云数据库MySQL、云数据库PostgreSQL等，您可以根据自己的需求选择适合的产品。具体产品介绍和使用方法，请参考腾讯云官方文档：
通过使用腾讯云的云数据库产品，您可以轻松地进行数据库的部署、管理和扩展，提高应用程序的可靠性和性能。
相关·内容
2回答
DatabaseError：(snowflake.connector.errors.DatabaseError) 250001 (08001)：未能连接到DB：*. connect 1。指定了不正确的用户名或密码。
当我试图用sqlalchemy连接到雪花时，我得到了上面的错误。我的凭据有。所以我试着使用urllib.parse。但是它仍然无法连接
下面是我使用的代码
import pandas as pd
import snowflake.connector
#from snowflake.sqlalchemy import URL
from sqlalchemy import create
浏览 12提问于2022-02-14得票数 0
1回答
好的，这是我的用例。我必须连接到不同类型的数据库(MSSQL，oracl，MYSQL等)。对于每个数据库，我都有.sql文件。由于sqlalchemy似乎不能运行.sql文件，所以我们需要通过连接从.sql文件中逐个打开并执行语句。
所以伙计们，我有这些信息，我想使用SQL Alchemy进行连接。
<db type="MSSQL" version="2005" patch_level="SP2" port="1433" id="MSSQLSERVER"/>
其中MSSQLServer是实例。未提供数据
浏览 1提问于2013-09-25得票数 0
我试图在MSSQL数据库中添加一个新的自动递增行，并读取创建的id值。当我执行SQL语句时，运行良好，但当我试图从返回的ResultProxy对象查询行时，就会得到一个“函数序列错误”。
我使用SQL Alchemy (pyodbc)连接到数据库，并使用execute()运行文本查询。通过运行SQL命令很好。
这就是我正在尝试的；
from sqlalchemy import create_engine
from sqlalchemy.sql import text
dbstring = "mssql+pyodbc://<SNIPPED>"
engine = cre
浏览 1提问于2019-04-06得票数 2
我正在为我的应用程序使用SQL-alchemy，但是当我使用表达式语言查询结果时，我无法获得与在SQL工作台中相同的结果 SQL -工作台查询 SELECT DISTINCT(rule_id) FROM resultsdb.new_results where execution_id='2020-08-24 12:52:49.262783' and data_id='1T2C6'; 输出： ['R03', 'R04'] SQL -炼金术查询 engine.execute('use resultsdb')
conn
浏览 4提问于2020-08-24得票数 0
回答已采纳
我试图使用Python将Pandas数据文件上传到Server表，但我无法使用sqlalchemy成功地创建连接。我知道我首先需要使用create_engine()创建一个引擎对象，并使用engine.connect()创建一个连接对象，但是我在create_engine()中输入的字符串似乎不起作用。我试过以下几种方法：
engine = create_engine('mssql+pyodbc://myServer/myDB')
conn = engine.connect()
以及：
engine = create_engine('mssql+pyodbc://Ser
浏览 0提问于2019-03-18得票数 4
我在Centos7.5VM上部署了最新的气流，并将sql_alchemy_conn和result_backend更新到postgresql实例上的postgres数据库，并指定我的执行器为CeleryExecutor。在没有启用任何dag的情况下，即使没有启动气流调度程序，我也看到大约每5秒建立一次连接，然后准备运行SELECT 1和SELECT CAST('test plain returns' AS VARCHAR(60)) AS anon_1。
当启动调度程序并打开dags时，短时间连接的数量急剧增加。有人知道原因吗？这是心跳检查还是任务状态检查？在sql_alchemy
浏览 0提问于2019-08-18得票数 3
我试图一步一步地上传Kubernetes ()中的气流，但在执行的这一部分中，我遇到了以下问题：
到目前为止，对这一课题的研究还没有找到解决问题的办法，有没有人对该做什么有什么建议？
SQL_ALCHEMY_CONN=postgresql+psycopg2://$AIRFLOW_DB_USER:$AIRFLOW_DB_USER_PASSWORD@$KUBERNETES_POSTGRES_CLOUDSQLPROXY_SERVICE:$KUBERNETES_POSTGRES_CLOUDSQLPROXY_PORT/$AIRFLOW_DB_NAME
echo $SQL_ALCHEMY_CONN &g
浏览 1提问于2019-06-18得票数 9
回答已采纳
1回答
当使用SQL Alchemy抽象您的数据访问层并使用控制器作为从该抽象层访问对象的方式时，应该如何处理联接？
例如，假设您有一个Orders控制器类，它管理Order对象，以便为用户对象提供getOrder、saveOrder等方法和类似的控制器。
首先，你需要这些控制器吗？相反，您是否应该将SQL Alchemy视为处理数据访问的“关键”事物。当你有一种干净的声明式的方法来获取和持久化对象，而不需要直接编写SQL时，为什么还要为面向对象的控制器而烦恼呢？
一个原因可能是你可能想用直接的SQL或者Storm或者其他任何东西来代替SQL Alchemy。因此，让控制器类充当中间层有助于限制需要更
浏览 0提问于2010-05-29得票数 0
回答已采纳
我一直试图在SQLalchemy的帮助下连接到mssql数据库，但无法连接。我遇到了两种不同的错误-这是我的代码-
import sqlalchemy
from sqlalchemy import create_engine
engine =
create_engine("mssql+pymssql://username:password@DSNsource")
connection = engine.connect()
下面的代码
engine =
sqlalchemy.create_engine('mssql+pyodbc://user:password@se
浏览 1提问于2019-03-18得票数 4
回答已采纳
1回答
我们用芹菜进行气流1.10.1。面对多个打开的连接。在DAG启动时- UI挂起几分钟。
亮点：
所有节点都是BareMetal: CPU:40，MHz 2494.015，RAM 378 g，10 40网卡-
数据库连接没有被重用。
连接保持打开，而活动仅为5。
工作人员创建数百个连接，直到DB清除它们为止(900秒)
每个工人运行100根芹菜线。
MySQL>显示全局状态，如‘线程%’；
+-------------------------+--------- +
| Variable_name | Value |
浏览 0提问于2019-08-29得票数 4
1回答
我很好奇在通过read_sql_query阅读熊猫查询时，关闭连接的正确方法。我一直在用：
from sqlalchemy import create_engine
import pandas as pd
engine = create_engine('credentials')
data = pd.read_sql_query(sql_query, engine)
虽然传统用法似乎是这样的：
engine = create_engine('credentials')
connection = engine.connect()
result = connect
浏览 4提问于2017-05-01得票数 0
2回答
我正在使用postgres数据库运行airlfow本地执行器，我得到了一个：(psycopg2.OperationalError) FATAL: remaining connection slots are reserved
我的心声：
sql_alchemy_pool_size = 5 sql_alchemy_pool_recycle = 1800 sql_alchemy_reconnect_timeout = 300
尽管如此，我仍然可以看到，气流总是保持更多的连接打开比池大小。
我们怎样才能限制气流到实际上使用池限制？
airflow_version = 1.10.2；postgr
浏览 0提问于2019-03-12得票数 6
回答已采纳
我无法使用python从Unix连接到SQL server。
由于其他依赖关系，我无法将中解释的从SQL Server的ODBC driver 17替换为SQL Server的ODBC Driver 13的驱动程序。
有没有人能推荐一种替代方案？
代码：
import sqlalchemy as sa
from urllib import parse as db_parse
from sqlalchemy import event
params = db_parse.quote_plus(r"DRIVER={ODBC Driver 17 for SQL Server};SERVE
浏览 1提问于2019-05-09得票数 4
回答已采纳
我正在使用一台Windows 10计算机，尝试使用Python连接到SQL Serve (SQL Developer 2017)。我的代码如下：
从sqlalchemy导入连接引擎= create_engine('mssql+pymssql://Sonwabo:helpdeskNo1@localhost:1433/dbname') create_engine = engine.connect()
我收到以下错误: pymssql.OperationalError：(20009，b‘’DB Lib错误消息20009，严重性9：\n无法连接:自适应服务器不可用或不存在(本地主机:1
浏览 37提问于2020-02-06得票数 0
我使用SQL Alchemy的create_engine从Python连接到Snowflake数据库。我使用“外部浏览器”作为身份验证器参数。每次我运行此命令时，都会打开一个浏览器进行身份验证。如何在每次尝试连接到Snowflake时停止打开的浏览器？
浏览 41提问于2021-09-14得票数 0
我正在尝试创建一个连接到MS数据库的python脚本，并使用SQLAlchemy提供帮助。(我正在学习数据库和python)，但是我正在尝试创建到一个新数据库的连接，但是一直得到这个"create_engine“并没有在SQLAlchemy错误中定义。
from sqlalchemy import create_engine
import pyodbc
import pandas as pd
SERVER = 'BEAST-ACTIVE\SQLEXPRESS' #FIND SERVER NAME
DATABASE = 'SQLTUTORIAL' #
浏览 14提问于2022-07-01得票数 0
1回答
我正在尝试寻找用Python3编写的MySQL驱动程序，我可能会将其绑定到SQL Alchemy。所以它应该与DB-API2兼容。
唯一可以连接到中的MySQL数据库的驱动程序。但我不能将它与SQL Alchemy绑定。
那么，有没有其他我可以使用的驱动程序呢？
浏览 0提问于2011-10-24得票数 2
回答已采纳
我有一个在kubernetes和Vault中运行的Airflow应用程序。我已经在使用Vault管理某些气流连接，并且工作正常(这证明与Vault的连接工作正常)。 我现在正在尝试通过Vault配置Airflow的core.sql_alchemy_conn、celery.result_backend和celery.broker_url，就像前面提到的here。 在我的values.yaml中 secrets_backend_kwargs:
auth_type: 'kubernetes'
kubernetes_role: 'role-id'
conn
浏览 24提问于2021-07-29得票数 0
回答已采纳
有人能告诉我Informix的Sql-Alchemy项目的状态吗？我对Python比较陌生。我使用过Dbi和SQL-Alchemy for postgres，并完成了这两项工作。 我花了很多时间尝试让Informix正常工作。我发现GitHub for sql-alchemy上的说明很难理解，我对它还没有“准备好”的评论感到厌烦。 我已经使IfxPy模块工作了，我也使IfxPyDbi工作了。如果execute方法返回一个字典(如IfxPy.fetch_assoc)，我很乐意使用IFxPyDbi，但我只能让它返回元组。 对于开始使用Informix开发python项目的最佳方法，有人有什么建议
浏览 19提问于2020-04-19得票数 1
我想使用sqlalchemy和python连接到一个sql服务器数据库。但是，当我运行下面的代码时，会得到以下错误
OperationalError：(pyodbc.OperationalError) ('08001'，‘08001SQLServer本机客户端11.0SQLServer网络接口:定位服务器/实例指定的xFFFFFFFF错误。(-1) (SQLDriverConnect)；08001SQLServer本机客户端11.0Login超时过期(0)；08001SQLServer本机客户端11.0A在建立到Server的连接时发生网络相关或特定于实例的错误。找不到或无法
浏览 0提问于2019-07-05得票数 1
在.cfg文件中，我使用user: airflow_admin和password：sql_alchemy_conn = postgresql+psycopg2://airflow_admin:pass@localhost:5432/airflow_backend将sql alchemy连接到Postgres 我如何匿名，这样密码就不会显示出来？是否创建一个.env文件并将密码存储为变量，然后在.cfg conn字符串中引用该变量？ 我阅读了以下内容，但举个例子会有所帮助：https://airflow.readthedocs.io/en/stable/howto/set-config.htm
浏览 17提问于2020-04-09得票数 1
我尝试配置Airbnb AirFlow来使用CeleryExecutor，如下所示：
我将airflow.cfg中的executer从SequentialExecutor更改为CeleryExecutor
# The executor class that airflow should use. Choices include
# SequentialExecutor, LocalExecutor, CeleryExecutor
executor = CeleryExecutor
但我得到以下错误：
airflow.configuration.AirflowConfigException: e
浏览 0提问于2016-04-24得票数 15
下面是我要完成的任务的一些背景:我的工作创建了一个应用程序，该应用程序将信息存储在SQL数据库中，用于我们所做的每一项工作。我正在尝试使用python自动化我们的一些工作流过程，但我希望能够访问数据库中的信息。
据我所知，要做到这一点，我需要将数据库连接到SQL服务器。我正在尝试使用SQLAlchemy和pyodbc来完成这个任务。作为应用程序的一部分，我使用Microsoft 2008 R2和SQLServerNativeClient10.0作为驱动程序。
问题是我无法使用SQLAlchemy或pyodbc使用create_engine()或connect()方法连接到SQL服务器。下面我尝
浏览 0提问于2018-12-13得票数 2
回答已采纳
我现在正在用蟒蛇和熊猫来转移一些数据。
这里，我在现有数据库中读到的数据类型有点卡住了，在Byte中，SQL Alchemy定义在Char中。
例如
from sqlalchemy.dialects.oracle import VARCHAR2
dtyp = {'COLUMN': VARCHAR2(12)}
df.to_sql(<tableName>, engine.connect(), schema=<schema>, if_exists='replace', index=False, chunksize=1000, dtype=t
浏览 0提问于2019-01-31得票数 2
回答已采纳
我必须与用户连接到Server。在服务器上，我需要从server读取到python，然后从python写入Server。
当我与一个用户登录时，无论我使用Windows身份验证还是Server身份验证，连接都很顺利，代码如下：
Server身份验证：
import sqlalchemy
engine = sqlalchemy.create_engine("mssql+pyodbc://myservername/mydatabasename/driver=SQL+Server+Native+Client+11.0?Trusted_Connection = no/UID = sa/PWD
浏览 1提问于2019-10-06得票数 0
我正在尝试将Pandas DataFrame上传到SQL server表。从阅读来看，sqlalchemy to_sql方法似乎是一个很好的选择。但是，我无法让create_engine建立连接。
我能够连接到数据库，通过Windows身份验证检索数据。下面是我使用的连接字符串：
cnxn = pyodbc.connect("Driver={SQL Server Native Client 11.0};"
"Server={server_name};"
"Databa
浏览 1提问于2020-06-16得票数 1
回答已采纳
我正在通过SQL Alchemy连接到postgres数据库。在测试中，COPY非常适合将行附加到本地数据库--它非常快。
COPY ratings FROM '/path/blah.csv' DELIMITER ',' CSV;
但是，我想要做的是通过SQL Alchemy连接将CSV文件复制到远程postgres数据库中。PG文档表明类似这样的东西
COPY ratings FROM STDIN '/path/blah.csv' DELIMITER ',' CSV;
也许行得通。但事实并非如此。我试过一堆合理的变种。
想法？谢
浏览 2提问于2013-08-09得票数 0
这是我的问题。我想获得一个用户页面列表，但我不想使用limit.then，我可以像这样使用sql：
SELECT * FROM (SELECT @rowNum:=@rowNum+1 AS rowNum,User FROM (SELECT
@rowNum:=0) r,User where User.Name=@Name ORDER BY User.Name) AS a
WHERE rowNum>=1 AND rowNum<=10
.net代码如下：
connection.Query<T>(sql, new{Name="name"}, transactio
浏览 13提问于2016-09-13得票数 0
当试图将连接到msssql服务器/数据库时，我一直遇到一个奇怪的错误。我需要使用sqlalchemy，因为它是(据我所知)连接熊猫数据格式到mssql的唯一方法。
我试过用两种不同的方式连接sqlalchemy：
使用完全连接字符串：
导入sqlalchemy作为sa导入urllib.parse as ulp =r‘’DRIVER={SQL usrCnnStr = ulp.quote_plus( usrCnnStr ) usrCnnStr =“mssql+pyodbc://?odbc://?odbc=%s”% usrCnnStr engine = sa.create_engine(usrC
浏览 5提问于2016-10-06得票数 2
回答已采纳
假设我有一个非常大的表，并且我想使用chunksize = 10000的pd.read_sql。 我现在的方法是： from sqlalchemy import create_engine
import pandas as pd
engine = create_engine('dialect://user:pass@host:port/schema')
with engine.connect() as conn:
for df in pd.read_sql('SELECT * FROM VERY_LARGE_TABLE', con=conn, chunk
浏览 106提问于2020-12-07得票数 0
1回答
将数据写入Server
、、、、
因此，我正在尝试使用to_sql函数为Microsoft编写一个数据框架。
我创建了一个引擎
engine = sqlalchemy.create_engine(
'mssql:///Server/Database?driver=SQL Server Native Client 11.0'
)
con = engine.connect()
switchers.to_sql('check',engine)
我得到的错误如下：
OperationalError：(pyodbc.OperationalError) ('08001'，‘0800
浏览 0提问于2018-10-28得票数 1
回答已采纳
我正在使用Alembic和SQL Alchemy。使用SQL Alchemy时，我倾向于遵循这样一种模式，即不将连接字符串与版本化代码一起存储。相反，我有包含任何机密信息的文件secret.py。我把这个文件名放到我的.gitignore中，这样它就不会出现在GitHub上了。
这个模式工作得很好，但是现在我开始使用Alembic进行迁移了。看起来我不能隐藏连接字符串。相反，在alembic.ini中，您将连接字符串放置为
# the 'revision' command, regardless of autogenerate
# revision_environment =
浏览 5提问于2014-03-05得票数 85
1回答
使用：
sql_alchemy_conn = db+postgresql://username:xxx@127.0.0.1:5432/airflow给出错误：
sqlalchemy.exc.NoSuchModuleError:无法加载插件: sqlalchemy.dialects:db.postgresql
在使用时：
sql_alchemy_conn = postgresql+psycopg2://username:xxx@localhost:5432/airflow我可以运行airlfow webserver -p 8080，但是在运行调度程序：airflow scheduler时
浏览 2提问于2017-11-12得票数 13
回答已采纳
当我从Python环境连接到Teradata时，有人能帮我解决下面的错误吗？
我正在使用ODBC驱动程序方法，我已经尝试了下面所有现有的方法来连接，但没有成功。
注意:如果你使用的是windows，你可以直接使用这些方法，但是当你在MAC操作系统上时，问题就来了(虽然不是所有的)。
使用TERADATA模块和SQL Alchemy。
import teradata
import pyodbc
server='111.00.00.00'
username = 'user'
password = 'pwd'
udaExec = teradat
浏览 0提问于2018-05-08得票数 0
我正在制作一个机器学习模型的原型，为对象生成“排序数据”。这些对象存储在通过SQLAlchemy抽象层访问的mysql中。现在，我想通过从第二个服务器(运行ML的服务器)获取的数据对这些数据进行过滤和排序。
到目前为止，我已经成功地通过将从ML-server拉出的id添加到IN filter语句来过滤数据：
.filter(Job.id.in_(list(sum(ai_match, ()))))
而ai_match是从ML服务器中提取的id的元组。这工作得很好，但我想按ML服务器中的similarity对列表进行排序。从SQL的角度来看，这只是两个数据库之间的内部连接：
`SELECT * F
浏览 3提问于2016-12-19得票数 2
只要使用可信连接，我就可以连接到服务器，SQL Alchemy或Pyodbc没有问题：
pyodbc.connect("Driver={SQL Server};Server=myServer;Port=1433;Database=myDB;trusted_connection=yes")
sqlalchemy.create_engine('mssql://myServer/myDB?trusted_connection=yes&driver=SQL+Server')
但我需要连接一个基本Windows身份验证的服务帐户。当我尝试像这样添加UID/PWD
浏览 3提问于2020-09-30得票数 0
回答已采纳
3回答
为一个页面提供多个数据库
、、、
我拥有:多个相同的数据库和一个SQL-Alchemy设置。
我需要实现:一个单一的"Flask“功能能够查询所有的数据库。所有其他函数只需要访问其中一个数据库。
数据库已经存在，我正在从它们加载数据。
最初，我只使用SQL-Alchemy抽象层，没有任何Flask模型。下面是代码的样子：
app = Flask(__name__)
app.config.from_object('myflaskapp.config.settings')
metadata = None
def connect_db():
engine = create_engine(app.co
浏览 4提问于2013-03-22得票数 0
回答已采纳
我想在Python中优化SQL Alchemy中的表？(SQL Lite)
我们该如何继续呢？是否有必要按日期排序以提高性能？
浏览 13提问于2016-09-15得票数 0
1回答
我需要在应用程序中的全局级别应用查询超时。查询:使用MySQL 5.7执行此操作：SET SESSION max_execution_time=1。我使用的是MySQL 5.6，目前无法升级。任何使用SQL Alchemy的解决方案都会有所帮助。
浏览 4提问于2019-01-02得票数 9
气流环境变量(例如，AIRFLOW__CORE__SQL_ALCHEMY_CONN)和一个秘密环境变量(AIRFLOW__CORE__SQL_ALCHEMY_CONN_SECRET)？
浏览 1提问于2020-11-24得票数 0
我试图用sqlalchemy连接到Google实例，以便使用Pandas to_sql函数。我的实例有一个内部IP地址。
我有以下几点要做：
import MySQLdb
def get_con():
return MySQLdb.connect(host='<IP Address>', user='root')
然而，当我使用sqlalchemy时：
import sqlalchemy
def get_con():
s = 'mysql://root@<IP Address>'
engine
浏览 1提问于2018-11-09得票数 1
回答已采纳
我希望将三个表连接在一起，以便找到第三个表的id的值。SQL语句工作正常，如下所示： SELECT table_three.id from table three
JOIN (table_one JOIN table_two ON table_one.id = table_two.table_one_id)
ON table_three.table_two_id = table_two.id
WHERE table_one.id = x AND table_two.external_id = y AND table three.external_id = z 对于这样的代码
浏览 28提问于2021-09-13得票数 0
1回答
我试图使用云函数Python脚本连接运行PostgreSQL 11的Cloud。理想情况下，我希望使用一个简单的pandas.DataFrame.to_sql()连接到DB，这需要一个sqlalchemy.create_engine()来连接。
这是我当前的尝试(我尝试了使用/不带/.s.PGSQL.5432后缀)：
engine = sqlalchemy.create_engine('postgresql+psycopg2://USERNAME:PASSWORD@/DB_NAME?host=/cloudsql/INSTANCE_CONNECTION_NAME/.s.PGSQL.543
浏览 0提问于2019-09-14得票数 2
回答已采纳
1回答
我有一个脚本，其目的是接收CSV并在sql表中大量插入该数据。
我能够创建与服务器的连接，并使用查询插入数据，但一旦连接关闭，会话将回滚，所有数据将从我的表中删除。
在我做了一些研究之后，我认为这与创建一个会话和在关闭连接之前提交更改有关，但是我仍然不能正确地完成它，并希望得到一些帮助。
以下是我目前的代码：
#Creat SQL connection using sql alchemy
sql_engine = sqlalchemy.create_engine(
'mssql+pyodbc://server_name/tabl
浏览 7提问于2022-08-19得票数 0
我正在尝试对pandas dataframe使用sql查询。但是使用where子句有时会让人感到困惑。
由于我也已经在SQL中构建了查询，所以我尝试使用SQL ALchemy，但它首先需要创建一个与RDBMS.Unfortunately的连接我的数据在CSV中。
请告诉我是否可以直接在数据帧上使用它，以及如何使用它。
浏览 8提问于2020-03-05得票数 0
在使用SqlAlchemy研究SQL查询时，我一直面临一些奇怪的问题。
sqlstr = 'SELECT "City" from CHICAGO_SCHOOLS;'
with engine.connect() as conn:
result = conn.execute(text(sqlstr))
print (result.all())
上面的查询返回数百个"Chicago“作为结果。所以我只想得到一个独特的结果：
sqlstr = 'SELECT DISTINCT "City" from CHICAGO_SCH
浏览 9提问于2022-06-09得票数 0
回答已采纳
1回答
气流中外部连接的连接池
、、、、
我试图找到一种方法，连接池管理外部连接创建的气流。
气流版本: 2.1.0
Python版本: 3.9.5
气流数据库: SQLite
创建外部连接: MySQL和雪花
我知道airflow.cfg文件中有一些属性
sql_alchemy_pool_enabled = True
sql_alchemy_pool_size = 5
但是这些属性是用来管理气流内部DB的，在我的例子中，这是SQLite。
我有很少的任务是读取或写入MySQL和雪花的数据。
snowflake_insert = SnowflakeOperator(
task_id='insert_sn
浏览 4提问于2021-06-14得票数 4
回答已采纳
我正在尝试连接mysql数据库，使用选项1可以很好地工作：
from sqlalchemy import create_engine
engine = create_engine('mysql://root:root@localhost/lend', echo=True)
cnx = engine.connect()
x = cnx.execute("SELECT * FROM user")
但在这里进行分析：
from pandas.io import sql
xx = sql.read_frame("SELECT * FROM user",
浏览 0提问于2013-12-05得票数 9
回答已采纳
1回答
对于将后端连接从SQLite更改为Server，我有一个问题。传入sql_alchemy_conn的正确连接字符串后，我运行以下命令：airflow initdb。我得到以下错误：
sqlalchemy.exc.ProgrammingError：(pyodbc.ProgrammingError) ('42000'，"42000ODBC驱动程序13“用于SQL ServerA表只能有一个时间戳列。由于表'task_reschedule‘已经有一个，所以不能添加'start_date’列。(2738) (SQLExecDirectW)")
浏览 2提问于2019-02-15得票数 1
回答已采纳
我正在尝试读一个表，修改一个列，然后写到另一个表。我遵循了可用的文档并运行了以下代码。它不会给出任何错误，但任务也不会执行。 我尝试删除转换步骤，然后写入信息。 import sqlalchemy
import bonobo
import bonobo_sqlalchemy
def get_services():
return {
'sql_alchemy.engine': sqlalchemy.create_engine('postgresql://postgres:password@localhost:5432/postgres'
浏览 18提问于2019-05-07得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
