python - 如何在vertica复制命令中保存/复制未在csv列列表中列出的表列的值

Question

我正在使用以下代码将数据从 csv 复制到 vertica 表。

copy_command = 'COPY cb.table_format2 (ACC_NO, REF_NO, CUSTOMER_NAME, ADDRESS) FROM STDIN '\
    'ENCLOSED BY \'"\' delimiter \',\' SKIP 1 '\
    'exceptions \'' + file_path_exception + '\' rejected data \'' + file_path_rejected + '\';'
with open(file_path, "rb") as inf:
            cur.copy(copy_command, inf)

我在 vertica 表中有另一个名为“FileId”的字段，我想用本地变量的值填充它，以便稍后我可以检查哪些数据是针对哪个 fileId 输入的，并且在我 future 的需求中，我还也想在其他列中保存创建日期和用户 session ID。

请让我知道我该怎么做？这是否可能？如果无法做到这一点，那么还有什么其他方法可以确保根据哪个时间戳和用户 session 保存/复制哪些数据？

感谢您提前提供帮助。

更新:-我正在使用 python 3 和 vertica_python 模块从 python 连接到 vertica。

Answer 1

您需要使用 AS 将 sql 表达式传递到字段。您没有提及您正在使用哪个 python 模块，但您可以将其作为文字来执行。添加一个新的字段条目，如下所示:

FILEID AS 123456

然后让你的字符串看起来像这样(可能使用格式化程序或绑定(bind)值)。