小编all*_*tej的帖子

我一直在使用无状态服务编程模型,但我没有真正重写RunAsync方法来运行应用程序逻辑.你什么时候会覆盖这个方法？

目前运行气流 1.10.15。想在升级到 2+ 之前执行一些测试。这样就安装到了pip install apache-airflow-upgrade-check安装成功的调度程序pod中。所以我然后运行该命令airflow upgrade_check，但它没有返回我预期的结果。它在终端中给了我这个输出

[2021-06-15 21:02:38,637] {{settings.py:233}} DEBUG - Setting up DB connection pool (PID 15732)
[2021-06-15 21:02:38,637] {{settings.py:300}} DEBUG - settings.prepare_engine_args(): Using pool settings. pool_size=5, max_overflow=10, pool_recycle=1800, pid=15732
[2021-06-15 21:02:38,735] {{sentry.py:179}} DEBUG - Could not configure Sentry: No module named 'blinker', using DummySentry instead.
[2021-06-15 21:02:38,754] {{__init__.py:45}} DEBUG - Cannot import  due to  doesn't look like a module path
[2021-06-15 21:02:38,916] {{cli_action_loggers.py:42}} DEBUG - Adding <function default_action_log at 0x7f9a637c3a70> to pre execution …

有问题的文件是replicatorshared.log，它是我机器上最大的单个文件，甚至比 Windows 10 交换文件还要大。我可以停止集群并删除文件，在集群启动时它会再次创建。

• 我可以控制这个文件的初始大小吗？

• 这个文件是用来做什么的，一开始就需要这么大？

我有循环创建任务的列表。该列表的大小是静态的。

        for counter, account_id in enumerate(ACCOUNT_LIST):
            task_id = f"bash_task_{counter}"
            if account_id:
                trigger_task = BashOperator(
                    task_id=task_id,
                    bash_command="echo hello there",
                    dag=dag)
            else:
                trigger_task = BashOperator(
                    task_id=task_id,
                    bash_command="echo hello there",
                    dag=dag)
                trigger_task.status = SKIPPED # is there way to somehow set status of this to skipped instead of having a branch operator?
            trigger_task

我手动尝试过此操作，但无法跳过该任务：

        start = DummyOperator(task_id='start')
        task1 = DummyOperator(task_id='task_1')
        task2 = DummyOperator(task_id='task_2')
        task3 = DummyOperator(task_id='task_3')
        task4 = DummyOperator(task_id='task_4')

        start >> task1
        start >> task2

        try:
            start >> task3
            raise AirflowSkipException
        except AirflowSkipException …

我有一个 PDF 资源的 URL，但它不能通过文件名来识别。该请求如下所示：

GET /api/docs/12345
Accept: application/pdf

响应是：

Status: 200 OK
Content-Type: application/pdf
Content-Disposition: attachment; filename="sample.pdf"

当我使用 Postman 调用 api 时，它会提示使用默认文件名“response”保存文件。因此文件保存为“response.pdf”。我需要使用 RestTemplate 客户端以编程方式执行此操作。我如何捕获响应，以便我可以提取文件名（如上面的响应中所示，它是sample.pdf），并且我可以相应地保存文件，而不是诸如“response.pdf”之类的通用文件名