小编Inf*_*892的帖子

我已经尝试过常见的PostgreSQL答案,但似乎它不适用于Redshift:

SELECT  * FROM VALUES (1) AS q (col1);

ERROR: 42883: function values(integer) does not exist

我需要这个因为某些原因我无法使用UNION ALL.任何帮助将不胜感激.

我在将 xcom 值分配给 BashOperator 时遇到一些问题。

除 tmp_dir 之外的所有参数均已正确检索，tmp_dir 是 init_dag 期间生成的 xcom 值。我能够检索自定义运算符中的值，但无法在 BashOperator 中检索该值。我添加了我想到的三种不同方法的输出。

我认为一种方法可能是我可以将该值存储在变量中，但我也无法弄清楚如何存储。

任何帮助将不胜感激。

这是我的 DAG 代码：

import airflow
from airflow.models import DAG
from airflow.utils.dates import days_ago
from airflow.models import Variable
from utility import util
import os

from airflow.operators.bash_operator import BashOperator

from operators.mmm_operator import MMMOperator  #it is a custom operator
from operators.iftp_operator import IFTPOperator #it is another custom operator

AF_DATAMONTH = util.get_date_by_format(deltaMth=2,deltaDay=0,ft='%b_%Y').lower() #it gives a date in required format
AF_FILENM_1 = 'SOME_FILE_' + AF_DATAMONTH + '.zip'  #required …