{"id":36691,"date":"2023-05-17T10:32:15","date_gmt":"2023-05-24T03:33:04","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/"},"modified":"2024-04-30T04:36:21","modified_gmt":"2024-04-29T20:36:21","slug":"%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/","title":{"rendered":"\u4f7f\u7528Apache Airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa (2)"},"content":{"rendered":"

\u521b\u5efa\u4e00\u4e2aDAG<\/h1>\n

\u5728\u5b89\u88c5\u4e86Airflow\u7684\u76ee\u5f55\u4e0b\u7684\u201cdags\/\u201d\u6587\u4ef6\u5939\u4e2d\u521b\u5efa\u6587\u4ef6\u3002<\/p>\n

$ <\/span>touch <\/span>dags\/sample_dag.py\r\n<\/code><\/pre>\n
\u521b\u5efa\u4e00\u4e2a\u53ef\u4ee5\u6267\u884c\u4ee5\u4e0bETL\u5904\u7406\u7684DAG\u3002<\/p>\n
    \n
  1. \n
      \u5c06JSON\u5b57\u7b26\u4e32\u8fd4\u56de\u4e3a\u5b57\u5178\u53d8\u91cf<\/ol>\n<\/li>\n<\/ol>\n
       <\/p>\n
        \n
      1. \n
          \u4ece\u5b57\u5178\u53d8\u91cf\u4e2d\u63d0\u53d6\u503c\u5e76\u76f8\u52a0\u8fd4\u56de<\/ol>\n<\/li>\n<\/ol>\n
           <\/p>\n
            \u5c06\u76f8\u52a0\u7684\u603b\u503c\u6253\u5370\u5230\u6807\u51c6\u8f93\u51fa<\/ol>\n
            import<\/span> json<\/span>\r\nimport<\/span> pendulum<\/span>\r\nfrom<\/span> airflow.decorators<\/span> import<\/span> dag<\/span>,<\/span> task<\/span>\r\n\r\n\r\n@dag<\/span>(<\/span>\r\n    schedule<\/span>=<\/span>None<\/span>,<\/span>\r\n    start_date<\/span>=<\/span>pendulum<\/span>.<\/span>datetime<\/span>(<\/span>2023<\/span>,<\/span> 6<\/span>,<\/span> 25<\/span>,<\/span> tz<\/span>=<\/span>\"<\/span>UTC<\/span>\"<\/span>),<\/span>\r\n    catchup<\/span>=<\/span>False<\/span>,<\/span>\r\n    tags<\/span>=<\/span>[<\/span>\"<\/span>ETL<\/span>\"<\/span>],<\/span>\r\n)<\/span>\r\ndef<\/span> sample_dag<\/span>():<\/span>\r\n\r\n    @task<\/span>()<\/span>\r\n    def<\/span> extract<\/span>():<\/span>\r\n\r\n        data_string<\/span> =<\/span> '<\/span>{<\/span>\"<\/span>1001<\/span>\"<\/span>: 301.27, <\/span>\"<\/span>1002<\/span>\"<\/span>: 433.21, <\/span>\"<\/span>1003<\/span>\"<\/span>: 502.22}<\/span>'<\/span>\r\n\r\n        order_data_dict<\/span> =<\/span> json<\/span>.<\/span>loads<\/span>(<\/span>data_string<\/span>)<\/span>\r\n        return<\/span> order_data_dict<\/span>\r\n\r\n    @task<\/span>(<\/span>multiple_outputs<\/span>=<\/span>True<\/span>)<\/span>\r\n    def<\/span> transform<\/span>(<\/span>order_data_dict<\/span>:<\/span> dict<\/span>):<\/span>\r\n\r\n        total_order_value<\/span> =<\/span> 0<\/span>\r\n\r\n        for<\/span> value<\/span> in<\/span> order_data_dict<\/span>.<\/span>values<\/span>():<\/span>\r\n            total_order_value<\/span> +=<\/span> value<\/span>\r\n\r\n        return<\/span> {<\/span>\"<\/span>total_order_value<\/span>\"<\/span>:<\/span> total_order_value<\/span>}<\/span>\r\n\r\n    @task<\/span>()<\/span>\r\n    def<\/span> load<\/span>(<\/span>total_order_value<\/span>:<\/span> float<\/span>):<\/span>\r\n\r\n        print<\/span>(<\/span>f<\/span>\"<\/span>Total order value is: <\/span>{<\/span>total_order_value<\/span>:<\/span>.<\/span>2<\/span>f<\/span>}<\/span>\"<\/span>)<\/span>\r\n\r\n    order_data<\/span> =<\/span> extract<\/span>()<\/span>\r\n    order_summary<\/span> =<\/span> transform<\/span>(<\/span>order_data<\/span>)<\/span>\r\n    load<\/span>(<\/span>order_summary<\/span>[<\/span>\"<\/span>total_order_value<\/span>\"<\/span>])<\/span>\r\n\r\n\r\nsample_dag<\/span>()<\/span>\r\n\r\n<\/code><\/pre>\n
            \"image.png\"<\/div>\n
            \"image.png\"<\/div>\n
            \u63d0\u53d6\u65e5\u5fd7<\/h2>\n
            ac67b37461ee\r\n*** Found local files:\r\n***   * \/opt\/airflow\/logs\/dag_id=sample_dag\/run_id=manual__2023-06-25T13:38:09.170374+00:00\/task_id=extract\/attempt=1.log\r\n[2023-06-25, 22:38:10 JST] {taskinstance.py:1103} INFO - Dependencies all met for dep_context=non-requeueable deps ti=<TaskInstance: sample_dag.extract manual__2023-06-25T13:38:09.170374+00:00 [queued]>\r\n[2023-06-25, 22:38:10 JST] {taskinstance.py:1103} INFO - Dependencies all met for dep_context=requeueable deps ti=<TaskInstance: sample_dag.extract manual__2023-06-25T13:38:09.170374+00:00 [queued]>\r\n[2023-06-25, 22:38:10 JST] {taskinstance.py:1308} INFO - Starting attempt 1 of 1\r\n[2023-06-25, 22:38:10 JST] {taskinstance.py:1327} INFO - Executing <Task(_PythonDecoratedOperator): extract> on 2023-06-25 13:38:09.170374+00:00\r\n[2023-06-25, 22:38:10 JST] {standard_task_runner.py:57} INFO - Started process 584 to run task\r\n[2023-06-25, 22:38:10 JST] {standard_task_runner.py:84} INFO - Running: ['***', 'tasks', 'run', 'sample_dag', 'extract', 'manual__2023-06-25T13:38:09.170374+00:00', '--job-id', '419', '--raw', '--subdir', 'DAGS_FOLDER\/sample_dag.py', '--cfg-path', '\/tmp\/tmp2ctqlv0m']\r\n[2023-06-25, 22:38:10 JST] {standard_task_runner.py:85} INFO - Job 419: Subtask extract\r\n[2023-06-25, 22:38:10 JST] {task_command.py:410} INFO - Running <TaskInstance: sample_dag.extract manual__2023-06-25T13:38:09.170374+00:00 [running]> on host ac67b37461ee\r\n[2023-06-25, 22:38:10 JST] {taskinstance.py:1547} INFO - Exporting env vars: AIRFLOW_CTX_DAG_OWNER='***' AIRFLOW_CTX_DAG_ID='sample_dag' AIRFLOW_CTX_TASK_ID='extract' AIRFLOW_CTX_EXECUTION_DATE='2023-06-25T13:38:09.170374+00:00' AIRFLOW_CTX_TRY_NUMBER='1' AIRFLOW_CTX_DAG_RUN_ID='manual__2023-06-25T13:38:09.170374+00:00'\r\n[2023-06-25, 22:38:10 JST] {python.py:183} INFO - Done. Returned value was: {'1001': 301.27, '1002': 433.21, '1003': 502.22}\r\n[2023-06-25, 22:38:10 JST] {taskinstance.py:1350} INFO - Marking task as SUCCESS. dag_id=sample_dag, task_id=extract, execution_date=20230625T133809, start_date=20230625T133810, end_date=20230625T133810\r\n[2023-06-25, 22:38:10 JST] {local_task_job_runner.py:225} INFO - Task exited with return code 0\r\n[2023-06-25, 22:38:10 JST] {taskinstance.py:2653} INFO - 1 downstream tasks scheduled from follow-on schedule check\r\n<\/code><\/pre>\n
            \u8f6c\u6362\u65e5\u5fd7<\/h2>\n
            ac67b37461ee\r\n*** Found local files:\r\n***   * \/opt\/airflow\/logs\/dag_id=sample_dag\/run_id=manual__2023-06-25T13:38:09.170374+00:00\/task_id=transform\/attempt=1.log\r\n[2023-06-25, 22:38:11 JST] {taskinstance.py:1103} INFO - Dependencies all met for dep_context=non-requeueable deps ti=<TaskInstance: sample_dag.transform manual__2023-06-25T13:38:09.170374+00:00 [queued]>\r\n[2023-06-25, 22:38:11 JST] {taskinstance.py:1103} INFO - Dependencies all met for dep_context=requeueable deps ti=<TaskInstance: sample_dag.transform manual__2023-06-25T13:38:09.170374+00:00 [queued]>\r\n[2023-06-25, 22:38:11 JST] {taskinstance.py:1308} INFO - Starting attempt 1 of 1\r\n[2023-06-25, 22:38:11 JST] {taskinstance.py:1327} INFO - Executing <Task(_PythonDecoratedOperator): transform> on 2023-06-25 13:38:09.170374+00:00\r\n[2023-06-25, 22:38:11 JST] {standard_task_runner.py:57} INFO - Started process 587 to run task\r\n[2023-06-25, 22:38:11 JST] {standard_task_runner.py:84} INFO - Running: ['***', 'tasks', 'run', 'sample_dag', 'transform', 'manual__2023-06-25T13:38:09.170374+00:00', '--job-id', '420', '--raw', '--subdir', 'DAGS_FOLDER\/sample_dag.py', '--cfg-path', '\/tmp\/tmp8cf_c2w4']\r\n[2023-06-25, 22:38:11 JST] {standard_task_runner.py:85} INFO - Job 420: Subtask transform\r\n[2023-06-25, 22:38:11 JST] {task_command.py:410} INFO - Running <TaskInstance: sample_dag.transform manual__2023-06-25T13:38:09.170374+00:00 [running]> on host ac67b37461ee\r\n[2023-06-25, 22:38:11 JST] {taskinstance.py:1547} INFO - Exporting env vars: AIRFLOW_CTX_DAG_OWNER='***' AIRFLOW_CTX_DAG_ID='sample_dag' AIRFLOW_CTX_TASK_ID='transform' AIRFLOW_CTX_EXECUTION_DATE='2023-06-25T13:38:09.170374+00:00' AIRFLOW_CTX_TRY_NUMBER='1' AIRFLOW_CTX_DAG_RUN_ID='manual__2023-06-25T13:38:09.170374+00:00'\r\n[2023-06-25, 22:38:11 JST] {python.py:183} INFO - Done. Returned value was: {'total_order_value': 1236.7}\r\n[2023-06-25, 22:38:11 JST] {taskinstance.py:1350} INFO - Marking task as SUCCESS. dag_id=sample_dag, task_id=transform, execution_date=20230625T133809, start_date=20230625T133811, end_date=20230625T133811\r\n[2023-06-25, 22:38:11 JST] {local_task_job_runner.py:225} INFO - Task exited with return code 0\r\n[2023-06-25, 22:38:11 JST] {taskinstance.py:2653} INFO - 1 downstream tasks scheduled from follow-on schedule check\r\n<\/code><\/pre>\n
            \u52a0\u8f7d\u65e5\u5fd7<\/h2>\n
            ac67b37461ee\r\n*** Found local files:\r\n***   * \/opt\/airflow\/logs\/dag_id=sample_dag\/run_id=manual__2023-06-25T13:38:09.170374+00:00\/task_id=load\/attempt=1.log\r\n[2023-06-25, 22:38:13 JST] {taskinstance.py:1103} INFO - Dependencies all met for dep_context=non-requeueable deps ti=<TaskInstance: sample_dag.load manual__2023-06-25T13:38:09.170374+00:00 [queued]>\r\n[2023-06-25, 22:38:13 JST] {taskinstance.py:1103} INFO - Dependencies all met for dep_context=requeueable deps ti=<TaskInstance: sample_dag.load manual__2023-06-25T13:38:09.170374+00:00 [queued]>\r\n[2023-06-25, 22:38:13 JST] {taskinstance.py:1308} INFO - Starting attempt 1 of 1\r\n[2023-06-25, 22:38:13 JST] {taskinstance.py:1327} INFO - Executing <Task(_PythonDecoratedOperator): load> on 2023-06-25 13:38:09.170374+00:00\r\n[2023-06-25, 22:38:13 JST] {standard_task_runner.py:57} INFO - Started process 590 to run task\r\n[2023-06-25, 22:38:13 JST] {standard_task_runner.py:84} INFO - Running: ['***', 'tasks', 'run', 'sample_dag', 'load', 'manual__2023-06-25T13:38:09.170374+00:00', '--job-id', '421', '--raw', '--subdir', 'DAGS_FOLDER\/sample_dag.py', '--cfg-path', '\/tmp\/tmpfrt4zy13']\r\n[2023-06-25, 22:38:13 JST] {standard_task_runner.py:85} INFO - Job 421: Subtask load\r\n[2023-06-25, 22:38:13 JST] {task_command.py:410} INFO - Running <TaskInstance: sample_dag.load manual__2023-06-25T13:38:09.170374+00:00 [running]> on host ac67b37461ee\r\n[2023-06-25, 22:38:13 JST] {taskinstance.py:1547} INFO - Exporting env vars: AIRFLOW_CTX_DAG_OWNER='***' AIRFLOW_CTX_DAG_ID='sample_dag' AIRFLOW_CTX_TASK_ID='load' AIRFLOW_CTX_EXECUTION_DATE='2023-06-25T13:38:09.170374+00:00' AIRFLOW_CTX_TRY_NUMBER='1' AIRFLOW_CTX_DAG_RUN_ID='manual__2023-06-25T13:38:09.170374+00:00'\r\n[2023-06-25, 22:38:13 JST] {logging_mixin.py:149} INFO - Total order value is: 1236.70\r\n[2023-06-25, 22:38:13 JST] {python.py:183} INFO - Done. Returned value was: None\r\n[2023-06-25, 22:38:13 JST] {taskinstance.py:1350} INFO - Marking task as SUCCESS. dag_id=sample_dag, task_id=load, execution_date=20230625T133809, start_date=20230625T133813, end_date=20230625T133813\r\n[2023-06-25, 22:38:13 JST] {local_task_job_runner.py:225} INFO - Task exited with return code 0\r\n[2023-06-25, 22:38:13 JST] {taskinstance.py:2653} INFO - 0 downstream tasks scheduled from follow-on schedule check\r\n<\/code><\/pre>\n
            \u53ef\u4ee5\u770b\u5230\u300c\u8ba2\u5355\u603b\u91d1\u989d\u4e3a\uff1a1236.70\u300d\u5df2\u7ecf\u8f93\u51fa\u5230\u6807\u51c6\u8f93\u51fa\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
            \u521b\u5efa\u4e00\u4e2aDAG \u5728\u5b89\u88c5\u4e86Airflow\u7684\u76ee\u5f55\u4e0b\u7684\u201cdags\/\u201d\u6587\u4ef6\u5939\u4e2d\u521b\u5efa\u6587\u4ef6\u3002 $ touch dags\/s […]<\/p>\n","protected":false},"author":8,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-36691","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"\n\u4f7f\u7528Apache Airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa (2) - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528apache-airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa-2\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u4f7f\u7528Apache Airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa (2)\" \/>\n<meta property=\"og:description\" content=\"\u521b\u5efa\u4e00\u4e2aDAG \u5728\u5b89\u88c5\u4e86Airflow\u7684\u76ee\u5f55\u4e0b\u7684\u201cdags\/\u201d\u6587\u4ef6\u5939\u4e2d\u521b\u5efa\u6587\u4ef6\u3002 $ touch dags\/s […]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528apache-airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa-2\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-05-24T03:33:04+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-29T20:36:21+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d2aa737434c4406c4806f\/6-0.png\" \/>\n<meta name=\"author\" content=\"\u96c5, \u609f\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u96c5, \u609f\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"5 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/\",\"name\":\"\u4f7f\u7528Apache Airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa (2) - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-05-24T03:33:04+00:00\",\"dateModified\":\"2024-04-29T20:36:21+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/f044a4b7fa4ee2701702942002419ca6\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u4f7f\u7528Apache Airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa (2)\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/f044a4b7fa4ee2701702942002419ca6\",\"name\":\"\u96c5, \u609f\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/e71a913e914f1aad1efc391f92084294bac54bc782acd289638580134cf667a6?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/e71a913e914f1aad1efc391f92084294bac54bc782acd289638580134cf667a6?s=96&d=mm&r=g\",\"caption\":\"\u96c5, \u609f\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/yawu\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"\u4f7f\u7528Apache Airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa (2) - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528apache-airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa-2\/","og_locale":"zh_CN","og_type":"article","og_title":"\u4f7f\u7528Apache Airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa (2)","og_description":"\u521b\u5efa\u4e00\u4e2aDAG \u5728\u5b89\u88c5\u4e86Airflow\u7684\u76ee\u5f55\u4e0b\u7684\u201cdags\/\u201d\u6587\u4ef6\u5939\u4e2d\u521b\u5efa\u6587\u4ef6\u3002 $ touch dags\/s […]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528apache-airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa-2\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-05-24T03:33:04+00:00","article_modified_time":"2024-04-29T20:36:21+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d2aa737434c4406c4806f\/6-0.png"}],"author":"\u96c5, \u609f","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u96c5, \u609f","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"5 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/","name":"\u4f7f\u7528Apache Airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa (2) - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-05-24T03:33:04+00:00","dateModified":"2024-04-29T20:36:21+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/f044a4b7fa4ee2701702942002419ca6"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"\u4f7f\u7528Apache Airflow\u8fdb\u884c\u5de5\u4f5c\u6d41\u7a0b\u521b\u5efa (2)"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/f044a4b7fa4ee2701702942002419ca6","name":"\u96c5, \u609f","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/e71a913e914f1aad1efc391f92084294bac54bc782acd289638580134cf667a6?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/e71a913e914f1aad1efc391f92084294bac54bc782acd289638580134cf667a6?s=96&d=mm&r=g","caption":"\u96c5, \u609f"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/yawu\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8apache-airflow%e8%bf%9b%e8%a1%8c%e5%b7%a5%e4%bd%9c%e6%b5%81%e7%a8%8b%e5%88%9b%e5%bb%ba-2\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/36691","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/8"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=36691"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/36691\/revisions"}],"predecessor-version":[{"id":89717,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/36691\/revisions\/89717"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=36691"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=36691"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=36691"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}