Python psycopg2 : Copy result of query to another table

标签 python postgresql python-3.x psycopg2 data-pipeline

我在使用 python 中的 psycopg2 时遇到一些问题
我有两个不同的连接与相应的游标:

1. Source connection - source_cursor
2. Destination connection - dest_cursor

假设我想在 source_cursor 上执行一个选择查询:

SELECT id, date
FROM source_table
WHERE id > 200

这个查询的结果应该被插入到 dest_cursor 的表中

我调查了copy_fromcopy_to以及诸如 this 之类的例子.他们利用外部文件来复制数据,而我需要直接复制它而不使用文件。源数据库和目标数据库之间的直接连接是不可能的,否则我会在数据库端完成。

我认为可以使用 fetchall()INSERT.. 或者一些直接使我们能够复制数据的方法。

非常感谢任何有关类似示例链接的帮助

最佳答案

意识到这是一个重复的问题。 使用 Tuning Postgresql performance and memory use in a python workflow 中给出的方法找到了一种方法

相关:

  1. psycopg2: insert multiple rows with one query
  2. Psycopg2, Postgresql, Python: Fastest way to bulk-insert
  3. psycopg2 copy
  4. How to do virtual file processing? - 我们可以用它来使用 psycopg2 的副本

关于Python psycopg2 : Copy result of query to another table,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47090912/

相关文章:

python - 在python中添加两个矩阵

python - Maya 渲染设置问题

sql左连接给出重复的多个值

python - Matplotlib 中 X 轴中的换行符导致不希望的窗口大小调整/跳跃/闪烁行为

python - 在 Os.Rename 中强制覆盖

python - OpenCV inRange() 适用于 RGB 但不适用于 HSV 颜色空间

postgresql - 在Docker中运行PostgreSql

python - PostgreSQL 异常 : DB_Cursor: exception in execute: tuple concurrently updated

python - 输入 'n' 时无法打印最终语句

python - 如何使用字符串格式函数打印对象的表示形式?