你不能在循环外定义字符串,希望在循环内打印时填充它。相反,您必须在循环中构建字符串:

systems = ["prd1", "prd2", "frz1", "frz2", "dev"]
qgsystems = ["Prd1_v2", "Prd2_v2", "Frz1_v2", "Frz2_v2", "Devl_v2"]

for x, y in zip(systems, qgsystems):
    print(f"{{fn blah({x}_1_output.csv)}}select {y};")

输出:

{fn blah(prd1_1_output.csv)}select Prd1_v2;
{fn blah(prd2_1_output.csv)}select Prd2_v2;
{fn blah(frz1_1_output.csv)}select Frz1_v2;
{fn blah(frz2_1_output.csv)}select Frz2_v2;
{fn blah(dev_1_output.csv)}select Devl_v2;

不能直接在rabbitmq上发布python对象,因为发布的消息是一个字符串。

必须先序列化和反序列化对象,方法是使用 json.dumps 和 json.loads 或 pickle 模块。

但是,如果您可以引入外部依赖项(例如rabbitmq),那么使用适当的rdbms是一个选项,或者最好完全避免使用任何外部工具—使您的父进程负责队列,并使您的子进程以某种方式将结果返回给父进程。

如果您只想在查询时应用转换,请确保使用 search_analyzer (仅在查询/搜索时适用)而不是 analyzer (索引和查询时都适用)。