定期运行红移查询

我用过 cursor 方法使用 psycopg2 python中的函数。下面给出了示例代码。您必须在中设置所有红移凭据 env_vars 文件。 您可以使用设置查询 cursor.execute 。这里我标注了一个更新查询的尺寸,以便您可以在此位置设置查询(您可以设置多个查询)。之后,必须将此python文件设置为crontab或任何其他自动运行应用程序,以便定期运行查询。

import psycopg2
import sys
import env_vars

conn_string = "dbname=%s  port=%s  user=%s  password=%s  host=%s " %(env_vars.RedshiftVariables.REDSHIFT_DW ,env_vars.RedshiftVariables.REDSHIFT_PORT ,env_vars.RedshiftVariables.REDSHIFT_USERNAME ,env_vars.RedshiftVariables.REDSHIFT_PASSWORD,env_vars.RedshiftVariables.REDSHIFT_HOST)
conn = psycopg2.connect(conn_string);
cursor = conn.cursor();
cursor.execute("""UPDATE database.demo_table SET  Device_id = '123' where Device = 'IPHONE' or Device = 'Apple'; """);

conn.commit();
conn.close();