这是一个使用Apache Beam Python SDK和JDBC IO从Postgres数据库中读取数据的示例代码：

import apache_beam as beam
from apache_beam.io.jdbc import ReadFromJdbc

# 定义Postgres数据库的连接信息和查询语句
connection_config = {
    'url': 'jdbc:postgresql://localhost:5432/db_name',
    'drivername': 'org.postgresql.Driver',
    'username': 'username',
    'password': 'password',
}

query = 'SELECT * FROM table_name'

# 创建数据流并从Postgres数据库中读取数据
with beam.Pipeline() as pipeline:
    data = pipeline | ReadFromJdbc(connection_config=connection_config, query=query)

    # 进一步处理数据流，例如打印每条记录
    data | beam.Map(print)

在这个示例中，我们首先导入了必要的模块，然后定义了Postgres数据库的连接信息和查询语句。然后，我们使用ReadFromJdbc函数创建了一个数据流，并指定了连接信息和查询语句。最后，我们可以根据需要进一步处理数据流，例如使用beam.Map对每条记录进行打印。

请注意，你需要将示例中的localhost:5432/db_name、username和password替换为你实际的数据库连接信息，以及将table_name替换为你要从中读取数据的表名。

希望对你有帮助！