执行流程任务 - 在 SSIS 中无法正常工作

编码Dawg

我有一个 python 代码,它读取一个 csv 文件,在 sql 中创建一个表并在该表中插入记录。该代码工作得很好。SSIS 任务大约需要 2-3 分钟才能运行,它没问题,因为代码需要那么多时间,但它不会在数据库上创建任何内容。

这是我的代码

#Import the required libraries
import pandas
import pyodbc
import os

#Set the Current Directory
path="C:/Users/MOLAP/Desktop/Data Warehouse Project/1. Datasets/Structured Data"
os.chdir(path)

#Establish connection with the server and the database
conn_str = (
    r'DRIVER={ODBC Driver 13 for SQL Server};'
    r'SERVER=MOLAP;'
    r'DATABASE=EnergyUsageEffects_Database;'
    r'Trusted_Connection=yes;'
)

cnxn = pyodbc.connect(conn_str)

cursor = cnxn.cursor()

#If a table is present - Truncate it else create the table
if cursor.tables(table='EnergyConsumption_Electrical', tableType='TABLE').fetchone():
    cursor.execute("Truncate table EnergyConsumption_Electrical")
    cnxn.commit()
else:   
    cursor.execute("Create table EnergyConsumption_Electrical (CountryName nvarchar(255), Year nvarchar(255), Unit nvarchar(255), Indicator nvarchar(255), Product nvarchar(255), ConsumptionValue float) ")
    cnxn.commit()


#Read the CSV Inside the dataframe
df = pandas.read_csv("Electrical Energy Types.csv")

#Convert the dataframe into a list
ReqList = df.values.tolist()

#Loop through the list and Insert record after record inside the table
for i in range(len(ReqList)):
    Val1 = ReqList[i][0]
    Val2= ReqList[i][1]
    Val3= ReqList[i][2]
    Val4= ReqList[i][3]
    Val5= ReqList[i][4]
    Val6= ReqList[i][5]
    cursor.execute("insert into EnergyConsumption_Electrical (CountryName, Year, Unit, Indicator, Product, ConsumptionValue) values (?,?,?,?,?,?)", Val1, Val2, Val3, Val4, Val5, Val6)
    cnxn.commit()

这是我在SSIS上的配置,

在此处输入图片说明

我哪里出错了?

数字.aaron

步骤 1) 从您的包中删除此任务。

步骤 2) 创建一个数据流,该数据流具有指向您的 .csv 的平面文件源和指向您的 database.table 的 OLE DB 目标任务。

真的没有理由在这里重新发明轮子。SSIS 有本地工具可以使这项任务变得微不足道。

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

SSIS在“执行流程任务”的计算变量中插入空间

SSIS执行流程任务以将2个文件复制到新文件中

SSIS执行流程任务Python脚本

SSIS中的并行执行是否正常工作?

自定义SSIS工作流程任务

SSIS执行流程任务和Powershell扩展文件

SSIS中的条件执行SQL任务

执行SQL任务中的SSIS返回变量

多任务环境中的流程执行

执行流程任务无法在作业中执行 Rust 脚本

多次执行SSIS任务

SSIS执行SQL任务编辑器查询无法解析

错误:Android Studio中的任务执行失败,无法正常工作

SSIS - 数据流任务中未执行失败路径

解决CMD的简单执行流程任务0xC0029151的SSIS错误

使用SSIS流程任务压缩文件

Microsoft SSIS条件拆分无法正常工作

如果子容器处理失败,则在父容器中执行SSIS执行文件任务

工作流程已完成,未执行Airflow中的所有任务

SSIS包-通过SQL Job Agent触发时,脚本任务无法执行

SSIS脚本任务从Excel工作表中删除行

在SSIS脚本任务中激活特定的Excel工作表

脚本文件执行正常,但使用WinSCP在SSIS中失败

SSIS中脚本任务中的“由于脚本入口点无效而无法执行脚本”错误

在SSIS 2012的Integration Service目录中的“执行包任务”中设置包路径

如何避免SSIS中动态“执行程序包任务”中的错误?

我的执行SQL任务中添加了SSIS额外引号

尝试在SSIS执行SQL任务中传递变量时我缺少什么?

SQL执行任务中的SSIS变量表达式设置错误