要从Postgres Operator获取Airflow中受影响的行数，可以使用Python的PostgreSQL驱动程序（例如psycopg2）与Postgres数据库进行交互。以下是一个示例代码，演示如何使用psycopg2从Postgres Operator获取受影响的行数：

首先，确保已安装psycopg2库。可以使用以下命令来安装它：

pip install psycopg2

然后，您可以使用以下代码示例从Postgres Operator获取受影响的行数：

import psycopg2

# 连接到Postgres数据库
conn = psycopg2.connect(
    host="your_host",
    database="your_database",
    user="your_user",
    password="your_password"
)

# 创建游标对象
cur = conn.cursor()

# 执行SQL查询，例如更新或删除操作
cur.execute("UPDATE your_table SET your_column = 'new_value' WHERE your_condition")

# 获取受影响的行数
affected_rows = cur.rowcount

# 提交事务
conn.commit()

# 关闭游标和连接
cur.close()
conn.close()

# 打印受影响的行数
print(f"受影响的行数：{affected_rows}")

请在上述代码中替换以下信息：

• your_host：Postgres数据库的主机名或IP地址。
• your_database：要连接的数据库名称。
• your_user：用于连接数据库的用户名。
• your_password：连接数据库的用户密码。
• your_table：要更新或删除的表名。
• your_column：要更新的列名。
• your_condition：更新或删除的条件。

这段代码将连接到Postgres数据库，执行SQL查询（例如更新或删除操作），并获取受影响的行数。最后，它打印出受影响的行数。

请注意，这只是示例代码，您需要根据您的实际情况进行适当的修改和调整。