云作曲家气流插件使用

问题描述

我刚开始使用气流插件,有点困惑。

我在 GCP (composer-1.13.4-airflow-1.10.12) 上使用 Cloud Composer 作为托管服务运行它

我按照文档编写了插件,但真的不知道如何“使用”它

class TestAppBuilderBaseView(AppBuilderBaseView):
    @expose("/test")
    def test(self):
        return self.render("test_plugin/test.html",content="Hello Starlight!")
v_appbuilder_view = TestAppBuilderBaseView()
v_appbuilder_package = {"name": "Test View","category": "Test Plugin","view": v_appbuilder_view}

class AirflowTestPlugin(AirflowPlugin):
    name = "test_plugin"
    appbuilder_views = [v_appbuilder_package]

Cloud Composer UI 将我踢到 https://[alpha-numeric].appspot.com/admin/,但我似乎无法找到我的应用程序插件的公开路由。我试过 https://[alpha-numeric].appspot.com/admin/test 和 https://[alpha-numeric].appspot.com/test

我可以显示一个菜单链接插件,以便我知道我正在将文件上传到存储桶中的正确位置。

在这里遗漏了什么?

任何帮助将不胜感激,谢谢:)

解决方法

我不确定我是否完全理解您的问题,但是如果您想要任何类型的网络服务器插件工作,您必须按照 here 的说明禁用 dag 序列化。 在漫长的 Composer 重新启动后,它将在基于烧瓶和基于 appbuilder 的 ui 中工作。 source