使用AWS Glue和PySpark过滤JDBC接收

问题描述

我正在使用AWS glue从MysqL数据库提取数据。我知道在使用pyspark-JDBC提取数据时可以使用自定义查询。基于搜寻器进行提取时是否同样适用? 现在我正在使用这个:

datasource =glueContext.create_dynamic_frame.from_catalog(database="db_name",table_name="table_name")

是否有什么方法可以提取而不是整个表中的一部分?就像使用select * from table where column_x > value

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)