我正在使用sqlalchemy和pandas连接到db，并从sql表创建数据帧。unix_socket=/var/lib/mysql/mysql.sock"
print conn输出： File "runner_train_test.py"
浏览 30提问于2016-07-05得票数 0
1回答
我必须连接到不同类型的数据库(MSSQL，oracl，MYSQL等)。对于每个数据库，我都有.sql文件。由于sqlalchemy似乎不能运行.sql文件，所以我们需要通过连接从.sql文件中逐个打开并执行语句。engine = create_engine(
浏览 1提问于2013-09-25得票数 0
2回答
DatabaseError：(snowflake.connector.errors.DatabaseError) 250001 (08001)：未能连接到DB：*. connect 1。当我试图用sqlalchemy连接到雪花时，我得到了上面的错误。我的凭据有。所以我试着使用urllib.parse。但是它仍然无法连接import pandas as pd#from snowflake.sqlalchemy i
浏览 12提问于2022-02-14得票数 0
我正在尝试使用Pandas和Sql炼金术。这基本上就是我想要做的。如果我删除该表，它将创建它，但我希望它是附加的，而不必进行表重命名。我已经尝试过更新和更改所有库的版本。我不知所措。此外，在加载之前，我使用PYMSSQL读取数据，它可以很好地读取数据帧 Python命令 def writeDFtoSSDatabase(tgtDefiniton,df): if intbatchSize = int(tgtDefiniton.loadBatchSize) batchSize
浏览 80提问于2021-08-30得票数 0
我正在尝试使用odbc驱动程序连接我的一个远程数据库，该驱动程序是使用DSN配置的。但是我没有找到与create_engine对象相关的参数。
有人能帮上忙吗？
浏览 28提问于2017-03-05得票数 0
我正在为我的应用程序使用SQL-alchemy，但是当我使用表达式语言查询结果时，我无法获得与在SQL工作台中相同的结果 SQL -工作台查询 SELECT DISTINCT(rule_id) FROMresultsdb.new_results where execution_id='2020-08-24 12:52:49.262783' and data_id='1T2C6'; 输出： ['R03', &#x
浏览 4提问于2020-08-24得票数 0
回答已采纳
当我执行SQL语句时，运行良好，但当我试图从返回的ResultProxy对象查询行时，就会得到一个“函数序列错误”。我使用SQL Alchemy (pyodbc)连接到数据库，并使用execute()运行文本查询。通过运行SQL命令很好。这就是我正在尝试的；from sqlalchemy.sql import text
dbstring = "mssql+pyodbc
浏览 1提问于2019-04-06得票数 2
我想将当前的db模式与我当前的模型进行比较。虽然compare_metadata提供了所需的升级操作的一个很好的列表，但我也想打印出相关的SQL语句(类似于脱机alembic upgrade head --sql命令，但不会在之前实际生成迁移脚本文件create_enginediff_list = compare_metadata(
MigrationContext.configure(engine.connect()),
浏览 2提问于2018-08-28得票数 1
airflow.configuration.AirflowConfigException: error: cannot use sqlite with the CeleryExecutorsql_alchemy_conn = sqlite:////root/airflow/airflow.db发现下面的代码抛出了这个异常：
def _= 'Sequential
浏览 0提问于2016-04-24得票数 15
我有一个运行在Kubernetes上的Airflow应用程序，它使用Vault作为一个秘密后端。最近，我设法将我的配置值sql_alchemy_conn移动到存储库，因为它包含用户的密码。我可以看到它正在从秘密后端获取值，并且能够连接到数据库并运行迁移作业。我使用官方的helm图表来部署应用程序，这是它用来检查迁移是否正在运行的python代码 import airflowimport os
fromconfig.set_main_option(&
浏览 53提问于2021-07-29得票数 1
回答已采纳
1回答
我需要在oracle sql中插入一个数据帧，我能找到的最快的方法是sqlalchemy，但这似乎对我不利。sqlalchemy.engine import create_engineimport cx_Oracle
SQL_DRIVERnumberENGINE_PATH_WIN_AUTH = DIALECT
浏览 1提问于2021-09-06得票数 2
我正在尝试使用python中的SQL连接到Azure SQL数据库。数据库最近从on移到Azure，据我所知，azure不支持Windows。"mssql+pyodbc://@*Server*/*DB*?driver=SQL Server"
我尝试过其他几个连接字符串，但
浏览 0提问于2019-07-05得票数 3
回答已采纳
我试图使用Python将Pandas数据文件上传到Server表，但我无法使用sqlalchemy成功地创建连接。我知道我首先需要使用create_engine()创建一个引擎对象，并使用engine.connect()创建一个连接对象，但是我在create_engine()中输入的字符串似乎不起作用。create_engine('mssql+pyodbc://Driver={SQL Server};Se
浏览 0提问于2019-03-18得票数 4
气流环境变量(例如，AIRFLOW__CORE__SQL_ALCHEMY_CONN)和一个秘密环境变量(AIRFLOW__CORE__SQL_ALCHEMY_CONN_SECRET)？
浏览 1提问于2020-11-24得票数 0
我在Centos7.5VM上部署了最新的气流，并将sql_alchemy_conn和result_backend更新到postgresql实例上的postgres数据库，并指定我的执行器为CeleryExecutor当启动调度程序并打开dags时，短时间连接的数量急剧增加。有人知道原因吗？这是心跳检查还是任务状态检查？在sql_alchemy_pool_enabled = True中使用airflow.cfg，这些连接不应该更长吗？有没有一个日志，我可以找出这些联系的来
浏览 0提问于2019-08-18得票数 3
我有张桌子：
我试着用sqlalchemy导入这个表，代码是：import pandas.io.sql as sql
df = pd.read_sql'Taiwan','postalCode':'
浏览 1提问于2020-08-31得票数 1
回答已采纳
1回答
我们用芹菜进行气流1.10.1。面对多个打开的连接。在DAG启动时- UI挂起几分钟。worker58328 - worker60337 - worker62工人.cfgsql_alchemy_pool_size= 5sql_alchemy_reconnect_timeout
浏览 0提问于2019-08-29得票数 4
1回答
我有一个脚本，其目的是接收CSV并在sql表中大量插入该数据。 #Creat SQL connection using sql alchemy
sql_engine =
浏览 7提问于2022-08-19得票数 0
我正在尝试将Pandas DataFrame上传到SQL server表。从阅读来看，sqlalchemy to_sql方法似乎是一个很好的选择。但是，我无法让create_engine建立连接。我能够连接到数据库，通过Windows身份验证检索数据。下面是我使用的连接字符串：
浏览 1提问于2020-06-16得票数 1
回答已采纳
2回答
我正在使用postgres数据库运行airlfow本地执行器，我得到了一个：(psycopg2.OperationalError) FATAL: remaining connection slots arereservedsql_alchemy_pool_size = 5 sql_alchemy_pool_recycle = 1800 sql_alchemy_reconnect_timeout= 300
尽管如此，我仍然可以看到，气流总是保持更多的
浏览 0提问于2019-03-12得票数 6
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
