当我按照完整的代码运行时,什么也没有发生。请帮助我,我想在每个select查询周期更新表。有没有办法执行下面的代码。$query = "SELECT * FROM ab_rec WHERE username='$userid'" or die(mysql_error());$row['conversion_percent'] = ($conversions/$unique_visits
我正在尝试对从RDS迁移到Redshift的数据使用Glue for ETL。 据我所知,胶水书签只查找使用指定主键的新行,而不跟踪更新的行。但是,我正在处理的数据往往有频繁更新的行,我正在寻找可能的解决方案。我对pyspark还是个新手,所以如果可以在pyspark中做到这一点,我将非常感谢一些指导或正确方向的观点。如果在Spark之外还有可能的解决方案,我也很乐意听到。