python - 在 Python 中使用 SQL Server 文件流式传输
问题描述
我正在尝试在 python 中使用 SQL Server 2017 文件流。我使用的所有功能都通过 sqlalchemy,因此我试图找到一种使用它的方法,因为我没有在 sqlalchemy 或其他库中找到任何实现(可能遗漏了一些东西,如果是这样,请指出我的工作和测试实现)。
我决定根据https://github.com/VisionMark/django-mssql-filestream/blob/master/sql_filestream/win32_streaming_api.py使用 dll 来解决这个问题。但是,我对 OpenSqlFilestream 的调用失败并返回 -1 而不是文件句柄。我不知道问题是什么或如何解决它。
from ctypes import c_char, sizeof, windll
from sqlalchemy import create_engine
from sqlalchemy.orm import session_maker
import msvcrt
import os
msodbcsql = windll.LoadLibrary("C:\Windows\System32\msodbcsql17.dll")
engine = create_engine("mssql+pyodbc://user:pass@test/test?TrustedConnection=yes+driver=ODBC Driver+17+for+SQL+Server")
maker = session_maker(bind=engine)
session = session_maker()
## first query should begind transaction
path = session.execute("SELECT file_stream.PathName() FROM test_filetable").fetchall()[0][0]
## this returns str like "\\\\test\\*"
context = session.execute("SELECT GET_FILESTREAM_TRANSACTION_CONTEXT()").fetchall()[0][0]
## returns bytes
_context = (c_char*len(context)).from_buffer_copy(context)
## This call fails
handle = msodbcsql.OpenSqlFilestream(
path, # FilestreamPath
0, # DesiredAccess
0, # OpenOptions
_context, # FilestreamTransactionContext
sizeof(_context), # FilestreamTransactionContextLength
0 # AllocationSize
)
## this returns -1 instead of handle
## Never reached, but this should create usable file
desc = msvcrt.open_osfhandle(fsHandle, os.O_RDONLY)
_file = os.fdopen(desc, 'r')
所有查询都有效并输出(据我所知)正确的数据。
如何从 python (3.7) 获取对 SQL Server 2017 上文件的文件流访问权限?
编辑:我读取的对象达到千兆字节的大小,并且该过程只需要流访问。
解决方案
我的猜测是您的问题与
- SQLAlchemy 会话不仅仅是一个原始的 DB API 连接,和/或
- 事务上下文不适合您调用
OpenSqlFilestream
对于它的价值,以下适用于 CPython 3.7.2 和 pythonnet 2.4.0:
import clr
clr.AddReference("System.Data")
from System.Data import IsolationLevel
from System.Data.SqlClient import SqlCommand, SqlConnection
from System.Data.SqlTypes import SqlFileStream
from System.IO import File, FileAccess, FileOptions
# adapted from c# code at
# https://docs.microsoft.com/en-us/dotnet/framework/data/adonet/sql/filestream-data
connection_string = r"Data Source=(local)\SQLEXPRESS;Initial Catalog=myDB;Integrated Security=True"
con = SqlConnection(connection_string)
con.Open()
sql = """\
SELECT Photo.PathName(), GET_FILESTREAM_TRANSACTION_CONTEXT()
FROM employees WHERE EmployeeID = 1"""
cmd = SqlCommand(sql, con)
tran = con.BeginTransaction(IsolationLevel.ReadCommitted)
cmd.Transaction = tran
rdr = cmd.ExecuteReader()
rdr.Read()
path = rdr.GetString(0)
transaction_context = rdr.GetSqlBytes(1).Buffer
rdr.Close()
allocation_size = 0
input_stream = SqlFileStream(path, transaction_context,
FileAccess.Read, FileOptions.SequentialScan, allocation_size)
output_stream = File.Create(r"C:\Users\Gord\Desktop\photo.bmp")
input_stream.CopyTo(output_stream)
output_stream.Close()
input_stream.Close()
tran.Commit()
con.Close()
推荐阅读
- javascript - 复选框过滤器。(需要功能逻辑方面的帮助)
- ios - 使用自动布局快速添加阴影和仅左/右角半径
- c++ - 使用 Chemfiles 库读取轨迹文件时出错
- javascript - 防止 Ajax.Complete 中的循环
- windows - Heroku 推送在 Windows + Git bash 中失败
- ffmpeg - 我无法在带有淡入/淡出过渡的缩放和平移中设置视频持续时间
- java - 获取更新行的特定列
- javascript - 像帧缓冲区这样的画布在 chrome 上工作,但在 Firefox 上不工作
- python - 使用正则表达式提取并显示所有使用 Python 的接口的接口和方法状态
- android - 下载的图像显示在 android studio 但不是画廊