康达气流-文件夹结构

如何解决康达气流-文件夹结构

我在conda上安装了裸露的气流-我设法通过将其放置在路径中来创建自定义运算符：

function HomeScreen() {
  return (
    <dismissKeyboard>
      <View 
        style={{
          flex: 1,justifyContent: 'center',alignContent: 'center'
        }}
      >
        <Text>top bar navigation to dismiss keyboard</Text>
        <TextInput
          style={{
            width: 100,height: 30,borderColor: '#000',borderWidth: 1
          }}
          placeholder="Click here ..."
        />
      </View>
    </dismissKeyboard>
  );
}

const dismissKeyboard = ({ children }) => (
  <TouchableWithoutFeedback onPress={() => Keyboard.dismiss()}>
    {children}
  </TouchableWithoutFeedback>
);

然后从dag呼叫为：

airflow/dags/operators/custom_operator.py

我该如何实现文件夹结构：

from operators.custom_operator import CustomOperator

从dag中被叫为：

airflow/operators/custom_operator.py

如果您认为这是一种不好的方法-如果有更好的设计模式，请在您的答案/评论中指出，我们很乐意调整我的方法。

解决方法

有趣的是，这里的解决方案是在airflow.cfg（您的气流配置文件）中，将参数dags_folder移到一个目录上至$AIRFLOW_HOME，所以不必：

....
[core]
dags_folder = /home/user/airflow/dags
....

只要做到：

....
[core]
dags_folder = /home/user/airflow
....

气流显然会递归地查找dag，并仅捕获定义为dag的类...然后，您可以在dags/文件夹之外使用自定义运算符，实用程序功能，自定义传感器等来保持干净的文件夹结构。 / p>