| Search.setIndex({"docnames": ["_api/airflow/providers/alibaba/cloud/hooks/analyticdb_spark/index", "_api/airflow/providers/alibaba/cloud/hooks/index", "_api/airflow/providers/alibaba/cloud/hooks/oss/index", "_api/airflow/providers/alibaba/cloud/index", "_api/airflow/providers/alibaba/cloud/log/index", "_api/airflow/providers/alibaba/cloud/log/oss_task_handler/index", "_api/airflow/providers/alibaba/cloud/operators/analyticdb_spark/index", "_api/airflow/providers/alibaba/cloud/operators/index", "_api/airflow/providers/alibaba/cloud/operators/oss/index", "_api/airflow/providers/alibaba/cloud/sensors/analyticdb_spark/index", "_api/airflow/providers/alibaba/cloud/sensors/index", "_api/airflow/providers/alibaba/cloud/sensors/oss_key/index", "_api/airflow/providers/alibaba/index", "_api/tests/system/providers/alibaba/example_adb_spark_batch/index", "_api/tests/system/providers/alibaba/example_adb_spark_sql/index", "_api/tests/system/providers/alibaba/example_oss_bucket/index", "_api/tests/system/providers/alibaba/example_oss_object/index", "_api/tests/system/providers/alibaba/index", "changelog", "commits", "connections/alibaba", "index", "installing-providers-from-sources", "logging/index", "logging/oss-task-handler", "operators/analyticdb_spark", "operators/index", "operators/oss", "security"], "filenames": ["_api/airflow/providers/alibaba/cloud/hooks/analyticdb_spark/index.rst", "_api/airflow/providers/alibaba/cloud/hooks/index.rst", "_api/airflow/providers/alibaba/cloud/hooks/oss/index.rst", "_api/airflow/providers/alibaba/cloud/index.rst", "_api/airflow/providers/alibaba/cloud/log/index.rst", "_api/airflow/providers/alibaba/cloud/log/oss_task_handler/index.rst", "_api/airflow/providers/alibaba/cloud/operators/analyticdb_spark/index.rst", "_api/airflow/providers/alibaba/cloud/operators/index.rst", "_api/airflow/providers/alibaba/cloud/operators/oss/index.rst", "_api/airflow/providers/alibaba/cloud/sensors/analyticdb_spark/index.rst", "_api/airflow/providers/alibaba/cloud/sensors/index.rst", "_api/airflow/providers/alibaba/cloud/sensors/oss_key/index.rst", "_api/airflow/providers/alibaba/index.rst", "_api/tests/system/providers/alibaba/example_adb_spark_batch/index.rst", "_api/tests/system/providers/alibaba/example_adb_spark_sql/index.rst", "_api/tests/system/providers/alibaba/example_oss_bucket/index.rst", "_api/tests/system/providers/alibaba/example_oss_object/index.rst", "_api/tests/system/providers/alibaba/index.rst", "changelog.rst", "commits.rst", "connections/alibaba.rst", "index.rst", "installing-providers-from-sources.rst", "logging/index.rst", "logging/oss-task-handler.rst", "operators/analyticdb_spark.rst", "operators/index.rst", "operators/oss.rst", "security.rst"], "titles": ["<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba.cloud.hooks.analyticdb_spark</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba.cloud.hooks</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba.cloud.hooks.oss</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba.cloud</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba.cloud.log</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba.cloud.log.oss_task_handler</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba.cloud.operators.analyticdb_spark</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba.cloud.operators</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba.cloud.operators.oss</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba.cloud.sensors.analyticdb_spark</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba.cloud.sensors</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba.cloud.sensors.oss_key</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.alibaba</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.alibaba.example_adb_spark_batch</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.alibaba.example_adb_spark_sql</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.alibaba.example_oss_bucket</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.alibaba.example_oss_object</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.alibaba</span></code>", "Changelog", "Package apache-airflow-providers-alibaba", "Alibaba Cloud Connection", "<code class=\"docutils literal notranslate\"><span class=\"pre\">apache-airflow-providers-alibaba</span></code>", "Installing from sources", "Logging for Tasks", "Writing logs to Alibaba OSS", "Alibaba Cloud AnalyticDB Spark Operators", "Alibaba Cloud Operators", "Alibaba Cloud OSS Operators", "Releasing security patches"], "terms": {"appstat": 0, "sourc": [0, 2, 5, 6, 8, 9, 11, 12, 13, 14, 15, 16, 25, 27], "base": [0, 2, 5, 6, 8, 9, 11], "enum": 0, "analyticdb": [0, 6, 9, 18, 19, 26], "spark": [0, 6, 9, 18, 19, 26], "applic": [0, 6, 9], "state": 0, "see": [0, 19, 21], "http": [0, 22], "www": 0, "alibabacloud": 0, "com": [0, 22], "help": 0, "en": 0, "mysql": [0, 6, 9], "latest": [0, 19, 28], "api": [0, 2, 6], "doc": [0, 19], "adb": [0, 9], "2021": [0, 19, 22, 25, 27], "12": [0, 19, 22], "01": [0, 19], "struct": 0, "sparkappinfo": 0, "submit": [0, 6, 9, 25], "start": [0, 24], "run": [0, 18, 19, 22], "fail": [0, 5, 24], "kill": [0, 6], "succeed": 0, "complet": 0, "fatal": 0, "unknown": [0, 22], "analyticdbsparkhook": 0, "adb_spark_conn_id": [0, 6, 9], "adb_spark_default": [0, 6, 9, 20], "region": [0, 2, 6, 8, 9, 11, 15, 19, 25, 27], "none": [0, 2, 5, 6, 8, 9, 11, 22], "arg": [0, 2, 6, 19], "kwarg": [0, 2, 5, 6, 8, 9, 11], "basehook": [0, 2], "util": [0, 5, 11, 25, 27], "log": [0, 3, 12, 18, 19], "logging_mixin": [0, 5], "loggingmixin": [0, 5], "through": 0, "rest": [0, 6], "paramet": [0, 2, 5, 6, 8, 9, 11, 20], "str": [0, 2, 6, 8, 9, 11, 19], "The": [0, 2, 6, 8, 11, 20, 21, 22, 28], "connect": [0, 2, 8, 9, 11, 19, 24], "us": [0, 2, 6, 8, 11, 18, 19, 20, 22, 24, 25, 27, 28], "credenti": [0, 8, 11], "you": [0, 8, 9, 21, 22, 24, 28], "want": [0, 8, 9, 22, 28], "terminal_st": 0, "conn_name_attr": [0, 2], "alibabacloud_conn_id": [0, 2], "default_conn_nam": [0, 2], "conn_typ": [0, 2], "adb_spark": 0, "hook_nam": [0, 2], "submit_spark_app": 0, "cluster_id": [0, 6, 25], "rg_name": [0, 6, 25], "perform": [0, 20], "request": 0, "cluster": [0, 6, 25], "id": [0, 6, 22, 24], "3": [0, 6, 21], "0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 20, 21, 22, 23, 24, 25, 26, 27, 28], "data": [0, 6, 19], "lakehous": [0, 6], "name": [0, 2, 6, 8, 11, 19, 20, 27], "resourc": [0, 6, 11, 20, 25], "group": [0, 6, 25], "submit_spark_sql": 0, "sql": [0, 6, 25], "get_spark_st": 0, "app_id": [0, 6, 9], "fetch": 0, "specifi": [0, 2, 6, 11, 20], "identifi": [0, 9], "get_spark_web_ui_address": 0, "web": [0, 18, 19], "ui": [0, 18, 19], "address": 0, "get_spark_log": 0, "get": [0, 2, 6, 9, 22, 28], "kill_spark_app": 0, "static": [0, 2, 19], "build_submit_app_data": 0, "file": [0, 2, 5, 6, 8, 11, 18, 19, 22, 25], "class_nam": [0, 6, 25], "conf": [0, 5, 6], "jar": [0, 6, 25], "py_fil": [0, 6], "driver_resource_spec": [0, 6], "executor_resource_spec": [0, 6], "num_executor": [0, 6], "archiv": [0, 6], "build": [0, 19, 22], "path": [0, 2, 6, 8, 11, 24], "contain": [0, 6, 8, 22], "execut": [0, 6, 8], "java": [0, 6], "main": [0, 6, 22, 28], "sequenc": [0, 6, 9, 11, 19], "int": [0, 2, 6], "float": [0, 6], "command": [0, 6], "line": [0, 6, 19], "argument": [0, 6, 18, 19], "dict": [0, 6], "ani": [0, 5, 6, 22], "configur": [0, 6, 24], "properti": [0, 6, 11], "thi": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28], "python": [0, 5, 6, 18, 19, 21, 22], "specif": [0, 6, 19], "driver": [0, 6], "each": [0, 6], "executor": [0, 6], "number": [0, 6], "launch": [0, 6], "build_submit_sql_data": 0, "queri": [0, 6], "templat": [0, 6, 8, 18, 19], "get_adb_spark_cli": 0, "valid": [0, 6, 9, 22], "client": 0, "get_default_region": [0, 2], "default": [0, 19, 28], "from": [0, 2, 5, 11, 19, 25, 27, 28], "2": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 20, 21, 22, 23, 24, 25, 26, 27, 28], "7": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 20, 21, 22, 23, 24, 25, 26, 27, 28], "9": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28], "dev0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28], "i": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28], "an": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28], "experiment": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28], "featur": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28], "analyticdb_spark": [1, 3, 7, 10, 12], "oss": [1, 3, 5, 7, 11, 12, 18, 19, 20, 23, 26], "t": [2, 24], "provide_bucket_nam": 2, "func": 2, "unifi": 2, "bucket": [2, 8, 11, 18, 19, 20, 24], "kei": [2, 8, 11, 20, 22], "unify_bucket_name_and_kei": 2, "osshook": [2, 11, 24], "oss_conn_id": [2, 8, 11], "oss_default": [2, 8, 11, 20, 24], "interact": [2, 27], "oss2": [2, 21], "librari": 2, "get_conn": 2, "return": [2, 5, 11], "parse_oss_url": 2, "ossurl": 2, "pars": 2, "url": [2, 11, 20, 24], "type": [2, 5, 19, 20], "tupl": 2, "object_exist": 2, "bucket_nam": [2, 8, 11, 27], "check": [2, 5, 11, 19, 22], "object": [2, 8, 11, 27], "exist": [2, 5, 11, 21, 24], "true": [2, 5, 11, 24], "fals": [2, 5, 11, 25, 27], "bool": [2, 5], "get_bucket": 2, "load_str": 2, "load": [2, 5], "string": [2, 5, 19], "set": [2, 5], "upload_local_fil": 2, "upload": [2, 5, 8], "local": [2, 5, 8, 18, 19, 22, 25], "download_fil": 2, "local_fil": [2, 8], "download": [2, 8, 22], "like": [2, 8, 11], "save": [2, 8], "delete_object": 2, "delet": [2, 5, 6, 8, 18, 19], "list": [2, 8, 19, 25, 27], "delete_bucket": [2, 27], "create_bucket": [2, 15, 27], "creat": [2, 6, 8, 11, 22], "append_str": 2, "po": 2, "append": [2, 5], "remot": [2, 5, 18, 19], "posit": 2, "where": [2, 18, 19, 28], "read_kei": 2, "read": [2, 5, 24], "head_kei": 2, "meta": [2, 19], "info": 2, "key_exist": 2, "find": 2, "out": [2, 28], "whether": [2, 5], "storag": [2, 5, 24, 27], "get_credenti": 2, "hook": [3, 5, 6, 9, 11, 12, 18, 19, 20], "oss_task_handl": [3, 4, 12, 18, 19], "oper": [3, 12], "sensor": [3, 12], "oss_kei": [3, 10, 12], "get_default_delete_local_copi": 5, "delete_local_log": 5, "version": [5, 18, 19, 21, 22, 28], "6": [5, 21], "todo": 5, "when": [5, 6, 8, 9, 11, 18, 19, 25, 27, 28], "min": [5, 18, 19], "osstaskhandl": 5, "base_log_fold": 5, "oss_log_fold": 5, "filename_templ": 5, "file_task_handl": 5, "filetaskhandl": 5, "handler": [5, 18, 19], "handl": 5, "task": [5, 6], "instanc": [5, 6, 11], "extend": 5, "set_context": 5, "ti": 5, "context": [5, 6, 8, 9, 11, 19], "close": 5, "oss_log_exist": 5, "remote_log_loc": 5, "": [5, 9, 11, 19, 22], "locat": [5, 24], "els": 5, "oss_read": 5, "return_error": 5, "ar": [5, 19, 20, 21, 22, 28], "found": [5, 28], "error": [5, 18, 19], "messag": 5, "occur": 5, "otherwis": [5, 11], "oss_writ": 5, "write": [5, 23], "silent": 5, "overwritten": 5, "If": [5, 22, 24], "new": [5, 19, 27, 28], "successfulli": 5, "written": 5, "analyticdbsparkbaseoper": [6, 18, 19], "polling_interv": 6, "model": [6, 8, 28], "baseoper": [6, 8], "abstract": 6, "defin": [6, 9], "how": [6, 22], "user": [6, 20, 22, 24], "develop": [6, 28], "get_hook": [6, 9, 11, 18, 19], "deriv": [6, 8, 9], "same": [6, 8], "dictionari": [6, 8, 20], "render": [6, 8], "jinja": [6, 8], "refer": [6, 8, 9], "get_template_context": [6, 8], "more": [6, 8, 18, 19], "monitor_appl": 6, "poll_for_termin": 6, "pool": 6, "termin": [6, 9], "monitor": [6, 9], "on_kil": 6, "overrid": [6, 9], "method": 6, "clean": 6, "up": 6, "subprocess": 6, "thread": 6, "multiprocess": 6, "within": 6, "need": [6, 25, 27], "leav": [6, 11], "ghost": 6, "process": [6, 24], "behind": 6, "analyticdbsparksqloper": [6, 25], "underli": 6, "wrap": 6, "template_field": [6, 9, 11, 19], "spark_param": 6, "template_fields_render": 6, "analyticdbsparkbatchoper": [6, 25], "batch": 6, "osscreatebucketoper": [8, 27], "ossdeletebucketoper": [8, 27], "ossuploadobjectoper": [8, 27], "ossdownloadobjectoper": [8, 27], "ossdeletebatchobjectoper": [8, 27], "ossdeleteobjectoper": [8, 27], "analyticdbsparksensor": [9, 18, 19], "basesensoroper": [9, 11], "session": 9, "app": 9, "depend": [9, 19, 28], "option": [9, 20], "being": [9, 11], "modifi": 9, "pre": [9, 19], "poke": [9, 11], "osskeysensor": [11, 18, 19, 27], "bucket_kei": 11, "wait": 11, "present": 11, "valu": 11, "doe": 11, "support": [11, 18, 19, 20, 21], "folder": [11, 19, 22], "just": 11, "full": [11, 19], "style": [11, 19], "rel": 11, "root": 11, "level": [11, 19], "pleas": [11, 22], "pull": 11, "self": [11, 22], "itself": [11, 28], "cloud": [12, 18, 19, 21], "__version__": [12, 19], "env_id": [13, 14, 15, 16], "dag_id": [13, 14, 15, 16, 25, 27], "adb_spark_batch_dag": 13, "spark_pi": [13, 25], "test_run": [13, 14, 15, 16], "adb_spark_sql_dag": 14, "show_databas": 14, "oss_bucket_dag": 15, "oss_object_dag": 16, "create_object": 16, "example_adb_spark_batch": [17, 25], "example_adb_spark_sql": 17, "example_oss_bucket": [17, 27], "example_oss_object": 17, "apach": [18, 22, 25], "airflow": [18, 22, 24, 25, 27, 28], "provid": [18, 22, 24, 25, 27, 28], "alibaba": [18, 22, 23], "releas": [18, 19, 21], "onli": [18, 20, 28], "avail": [18, 22], "explain": [18, 19], "polici": [18, 28], "bump": [18, 19], "minimum": [18, 19, 21], "36017": [18, 19], "34728": [18, 19], "consolid": [18, 19], "manag": [18, 19, 22], "34435": [18, 19], "34434": [18, 19], "deprec": [18, 19], "instead": [18, 19], "34426": [18, 19], "respect": [18, 19], "soft_fail": [18, 19], "except": [18, 19, 28], "rais": [18, 19], "34157": [18, 19], "refactor": [18, 19], "simplifi": [18, 19], "code": [18, 19, 22, 25, 27], "33227": [18, 19], "condit": [18, 19], "len": [18, 19], "33564": [18, 19], "33225": [18, 19], "add": [18, 19], "31787": [18, 19], "drop": [18, 19, 22], "remov": [18, 19, 22], "30963": [18, 19], "30917": [18, 19], "29772": [18, 19], "move": [18, 19], "all": [18, 19, 20, 21, 28], "27196": [18, 19], "econom": [18, 19], "than": [18, 19], "27517": [18, 19], "replac": [18, 19], "urlpars": [18, 19], "urlsplit": [18, 19], "27389": [18, 19], "auto": [18, 19], "tail": [18, 19], "26169": [18, 19], "updat": [18, 19], "functool": [18, 19], "compat": [18, 19], "cached_properti": [18, 19], "24582": [18, 19], "ssl": [18, 19], "light": [18, 19], "logic": [18, 19], "docstr": [18, 19], "23891": [18, 19], "appli": [18, 19], "per": [18, 19], "24153": [18, 19], "mistakenli": 18, "ad": [18, 19], "install_requir": 18, "22382": 18, "enabl": [18, 19], "21785": [18, 19], "trove": 18, "classifi": [18, 19], "pypi": [18, 19, 28], "framework": 18, "10": [18, 19], "initi": 18, "integr": [19, 21, 25, 27], "includ": [19, 21, 28], "detail": [19, 22], "commit": 19, "chang": [19, 28], "For": [19, 22], "high": 19, "changelog": 19, "inform": [19, 28], "2023": 19, "07": 19, "subject": 19, "d0918d77ee": 19, "c905fe88d": 19, "11": [19, 22], "25": 19, "about": [19, 22, 28], "link": [19, 22], "yaml": 19, "35837": 19, "0b23d5601c": 19, "24": 19, "prepar": [19, 28], "2nd": 19, "wave": 19, "novemb": 19, "35836": 19, "99534e47f3": 19, "19": 19, "reproduc": 19, "35693": 19, "99df205f42": 19, "16": 19, "fix": [19, 28], "reappli": 19, "document": 19, "35686": 19, "1b059c57d6": 19, "08": 19, "1st": 19, "35537": 19, "d1c58d86de": 19, "28": 19, "3rd": 19, "octob": 19, "35233": 19, "3592ff4046": 19, "35187": 19, "dd7ba3cae1": 19, "upgrad": [19, 28], "ruff": 19, "292": 19, "35053": 19, "13": 19, "e9987d5059": 19, "34916": 19, "0c8e30e43b": 19, "05": 19, "99f320354b": 19, "04": 19, "import": [19, 22, 25, 27], "time": 19, "34402": 19, "7ebf4220c9": 19, "09": 19, "usag": 19, "34320": 19, "caee896403": 19, "18": 19, "0891742ecb": 19, "f8ae8dba66": 19, "21990ed894": 19, "34201": 19, "7696e416a": 19, "26": 19, "c077d19060": 19, "aug": 19, "33730": 19, "32feab4100": 19, "22": 19, "af0a4a0698": 19, "21": 19, "c645d8e40c": 19, "d401": 19, "airbyt": 19, "atlassian": 19, "inclus": 19, "33354": 19, "b5a4d36383": 19, "33291": 19, "4e83660f4c": 19, "06": 19, "225e3041d2": 19, "juli": 19, "rc2": 19, "32381": 19, "3878fe6fab": 19, "spuriou": 19, "header": 19, "32373": 19, "cb4927a018": 19, "32298": 19, "0bc689ee6d": 19, "d205": 19, "32214": 19, "09d4718d3a": 19, "27": 19, "improv": 19, "readm": 19, "structur": 19, "32125": 19, "f05beb7219": 19, "20": 19, "79bcc2e668": 19, "rc1": 19, "june": 19, "32001": 19, "8b146152d6": 19, "note": 19, "32015": 19, "a59076eae": 19, "02": 19, "d400": 19, "pydocstyl": 19, "31427": 19, "9fa75aaf7a": 19, "29": 19, "45548b9451": 19, "mai": [19, 20], "31416": 19, "abea189022": 19, "31393": 19, "f5aed58d9f": 19, "circular": 19, "caus": 19, "31379": 19, "d9ff55cf6d": 19, "31252": 19, "eef5bc7f16": 19, "03": 19, "autom": 19, "30994": 19, "a7eb32a5b2": 19, "30": 19, "d23a3bbed8": 19, "mechan": 19, "suspend": 19, "30422": 19, "55dbf1ff1f": 19, "april": 19, "30378": 19, "b6392ae5fd": 19, "2022": 19, "15": 19, "12c3c39d1a": 19, "27613": 19, "00af5c007": 19, "14": [19, 21], "8c15b0a6d1": 19, "9ab1a6a3e7": 19, "old": 19, "26872": 19, "78b8ea2f22": 19, "2a34dc9e84": 19, "23": 19, "normal": 19, "format": 19, "27205": 19, "f8db64c35c": 19, "septemb": 19, "26731": 19, "1f7b296227": 19, "06acf40a43": 19, "pep": 19, "563": 19, "postpon": 19, "evalu": 19, "annot": 19, "non": 19, "core": 19, "26289": 19, "d2459a241b": 19, "25030": 19, "0de31bd73a": 19, "insid": 19, "24672": 19, "510a6bab45": 19, "class": [19, 21], "24702": 19, "9c59831ee7": 19, "dcdcf3a2b8": 19, "24307": 19, "717a7588bc": 19, "descript": 19, "doubl": 19, "24292": 19, "aeabe994b3": 19, "24231": 19, "c23826915d": 19, "027b707d21": 19, "explanatori": 19, "contributor": 19, "24229": 19, "c887275bb8": 19, "migrat": 19, "exampl": [19, 22, 24, 25, 27], "dag": [19, 25, 27], "design": 19, "22437": 19, "24130": 19, "d19cb86660": 19, "31": 19, "d7dbfb7e26": 19, "bugfix": [19, 28], "22383": 19, "16adc035b1": 19, "march": 19, "22226": 19, "7bd8b2d7f3": 19, "f5b96315fe": 19, "feb": 19, "22056": 19, "d94fa37830": 19, "januari": 19, "delai": 19, "21439": 19, "6c3a67d4fc": 19, "21257": 19, "73c0d241d8": 19, "few": 19, "strai": 19, "21014": 19, "602abe8394": 19, "now": [19, 20], "sphinx": 19, "autoapi": 19, "typehint": 19, "20951": 19, "730db3fb77": 19, "fake": 19, "stub": 19, "20936": 19, "f8fd0f7b4c": 19, "introduc": 19, "mypi": 19, "20827": 19, "f77417eb0d": 19, "k8": 19, "20614": 19, "97496ba2b4": 19, "decemb": 19, "20523": 19, "d56e7b56bb": 19, "have": [19, 24, 28], "friendli": 19, "20571": 19, "a0821235fb": 19, "everywher": 19, "20565": 19, "3299064958": 19, "isort": 19, "pyi": 19, "20556": 19, "b5d520cf73": 19, "reinstat": 19, "default_arg": [19, 25, 27], "20423": 19, "73ab0edce5": 19, "20393": 19, "2fb5e1d0ec": 19, "declar": 19, "relat": 19, "20226": 19, "853576d901": 19, "19882": 19, "d9567eb106": 19, "19321": 19, "f5ad26dcdd": 19, "fixup": 19, "concaten": 19, "19099": 19, "840ea3efb9": 19, "18613": 19, "ef037e7021": 19, "start_dat": [19, 25, 27], "cleanup": 19, "misc": 19, "18597": 19, "0fe0b06bb0": 19, "miss": 19, "init": 19, "example_dag": 19, "directori": [19, 22], "18019": 19, "be75dcd39c": 19, "76ed2a49c6": 19, "lazili": 19, "individu": 19, "17682": 19, "75ca6543da": 19, "17200": 19, "17201": 19, "secur": 20, "token": 20, "servic": [20, 27], "st": 20, "sign": [20, 22], "schema": 20, "json": 20, "can": [20, 21, 22, 24, 28], "follow": [20, 22, 24, 25, 27, 28], "auth_typ": 20, "auth": 20, "access": [20, 24], "ak": 20, "access_key_id": 20, "access_key_secret": 20, "secret": 20, "top": [21, 22], "below": [21, 22], "via": [21, 22], "pip": [21, 22], "alibabacloud_adb20211201": 21, "1": [21, 25, 27], "alibabacloud_tea_openapi": 21, "page": 22, "describ": 22, "offici": 22, "also": 22, "most": 22, "choos": 22, "differ": 22, "select": 22, "down": 22, "left": 22, "sdist": 22, "whl": 22, "origin": 22, "checksum": 22, "signatur": 22, "softwar": 22, "foundat": 22, "asc": 22, "sha512": 22, "those": 22, "abov": [22, 24], "pgp": 22, "It": 22, "essenti": 22, "sha": 22, "gpg": 22, "well": 22, "relev": 22, "distribut": 22, "recommend": 22, "mirror": 22, "pgpk": 22, "ka": 22, "To": [22, 24], "binari": 22, "guid": 22, "pgpv": 22, "tar": 22, "gz": 22, "made": 22, "sat": 22, "sep": 22, "49": 22, "54": 22, "bst": 22, "rsa": 22, "cde15c6e4d3a8ec4ecf4ba4b6674e08ad7de406f": 22, "issuer": 22, "kaxilnaik": 22, "org": [22, 25], "good": [22, 28], "kaxil": 22, "naik": 22, "aka": 22, "gmail": 22, "warn": 22, "certifi": 22, "trust": 22, "There": 22, "indic": 22, "belong": 22, "owner": 22, "primari": 22, "fingerprint": 22, "cde1": 22, "5c6e": 22, "4d3a": 22, "8ec4": 22, "ecf4": 22, "ba4b": 22, "6674": 22, "e08a": 22, "d7de": 22, "406f": 22, "correct": 22, "do": 22, "worri": 22, "certif": 22, "why": 22, "By": 22, "server": 22, "previou": 22, "step": 22, "know": 22, "alreadi": 22, "sum": 22, "shasum": 22, "512": 22, "diff": 22, "should": [22, 28], "match": 22, "one": 22, "script": 22, "bin": 22, "bash": 22, "package_vers": 22, "package_nam": 22, "provider_download_dir": 22, "mktemp": 22, "d": 22, "dep": 22, "dest": 22, "curl": 22, "apache_airflow_providers_alibaba": 22, "py3": 22, "l": 22, "o": 22, "echo": 22, "la": 22, "onc": 22, "instruct": [22, 28], "chapter": 22, "temporari": 22, "don": 24, "properli": [24, 25, 27], "setup": 24, "cfg": 24, "must": 24, "store": 24, "suppli": 24, "either": 24, "remote_log": 24, "remote_base_log_fold": 24, "my": 24, "remote_log_conn_id": 24, "In": [24, 25, 27], "try": 24, "sever": [25, 27], "pi": 25, "logist": 25, "regress": 25, "we": [25, 27, 28], "test": [25, 27, 28], "system": [25, 27], "py": [25, 27], "datetim": [25, 27], "your": [25, 27], "max_active_run": [25, 27], "catchup": [25, 27], "task_id": [25, 27], "task1": [25, 27], "tmp": 25, "sparkpi": 25, "spark_lr": 25, "task2": [25, 27], "sparklr": 25, "watcher": [25, 27], "order": [25, 27], "mark": [25, 27], "success": [25, 27], "failur": [25, 27], "teardown": [25, 27], "trigger": [25, 27], "rule": [25, 27, 28], "part": [25, 27], "given": 27, "tag": 27, "independ": 28, "vulner": 28, "publish": 28, "separ": 28, "instal": 28, "alwai": 28, "done": 28, "branch": 28, "next": 28, "strict": 28, "semver": 28, "scope": 28, "major": 28, "break": 28, "minor": 28, "patchlevel": 28, "bug": 28, "receiv": 28, "so": 28, "critic": 28, "reason": 28, "band": 28, "which": 28, "case": 28, "stakehold": 28, "might": 28, "decid": 28, "cherri": 28, "pick": 28, "older": 28, "mix": 28, "govern": 28, "requir": 28, "interest": 28, "parti": 28}, "objects": {"airflow.providers": [[12, 0, 0, "-", "alibaba"]], "airflow.providers.alibaba": [[12, 1, 1, "", "__version__"], [3, 0, 0, "-", "cloud"]], "airflow.providers.alibaba.cloud": [[1, 0, 0, "-", "hooks"], [4, 0, 0, "-", "log"], [7, 0, 0, "-", "operators"], [10, 0, 0, "-", "sensors"]], "airflow.providers.alibaba.cloud.hooks": [[0, 0, 0, "-", "analyticdb_spark"], [2, 0, 0, "-", "oss"]], "airflow.providers.alibaba.cloud.hooks.analyticdb_spark": [[0, 2, 1, "", "AnalyticDBSparkHook"], [0, 2, 1, "", "AppState"]], "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook": [[0, 3, 1, "", "TERMINAL_STATES"], [0, 4, 1, "", "build_submit_app_data"], [0, 4, 1, "", "build_submit_sql_data"], [0, 3, 1, "", "conn_name_attr"], [0, 3, 1, "", "conn_type"], [0, 3, 1, "", "default_conn_name"], [0, 4, 1, "", "get_adb_spark_client"], [0, 4, 1, "", "get_default_region"], [0, 4, 1, "", "get_spark_log"], [0, 4, 1, "", "get_spark_state"], [0, 4, 1, "", "get_spark_web_ui_address"], [0, 3, 1, "", "hook_name"], [0, 4, 1, "", "kill_spark_app"], [0, 4, 1, "", "submit_spark_app"], [0, 4, 1, "", "submit_spark_sql"]], "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState": [[0, 3, 1, "", "COMPLETED"], [0, 3, 1, "", "FAILED"], [0, 3, 1, "", "FAILING"], [0, 3, 1, "", "FATAL"], [0, 3, 1, "", "KILLED"], [0, 3, 1, "", "KILLING"], [0, 3, 1, "", "RUNNING"], [0, 3, 1, "", "STARTING"], [0, 3, 1, "", "SUBMITTED"], [0, 3, 1, "", "SUCCEEDING"], [0, 3, 1, "", "UNKNOWN"]], "airflow.providers.alibaba.cloud.hooks.oss": [[2, 2, 1, "", "OSSHook"], [2, 1, 1, "", "T"], [2, 5, 1, "", "provide_bucket_name"], [2, 5, 1, "", "unify_bucket_name_and_key"]], "airflow.providers.alibaba.cloud.hooks.oss.OSSHook": [[2, 4, 1, "", "append_string"], [2, 3, 1, "", "conn_name_attr"], [2, 3, 1, "", "conn_type"], [2, 4, 1, "", "create_bucket"], [2, 3, 1, "", "default_conn_name"], [2, 4, 1, "", "delete_bucket"], [2, 4, 1, "", "delete_object"], [2, 4, 1, "", "delete_objects"], [2, 4, 1, "", "download_file"], [2, 4, 1, "", "get_bucket"], [2, 4, 1, "", "get_conn"], [2, 4, 1, "", "get_credential"], [2, 4, 1, "", "get_default_region"], [2, 4, 1, "", "head_key"], [2, 3, 1, "", "hook_name"], [2, 4, 1, "", "key_exist"], [2, 4, 1, "", "load_string"], [2, 4, 1, "", "object_exists"], [2, 4, 1, "", "parse_oss_url"], [2, 4, 1, "", "read_key"], [2, 4, 1, "", "upload_local_file"]], "airflow.providers.alibaba.cloud.log": [[5, 0, 0, "-", "oss_task_handler"]], "airflow.providers.alibaba.cloud.log.oss_task_handler": [[5, 2, 1, "", "OSSTaskHandler"], [5, 5, 1, "", "get_default_delete_local_copy"]], "airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler": [[5, 4, 1, "", "close"], [5, 4, 1, "", "hook"], [5, 4, 1, "", "oss_log_exists"], [5, 4, 1, "", "oss_read"], [5, 4, 1, "", "oss_write"], [5, 4, 1, "", "set_context"]], "airflow.providers.alibaba.cloud.operators": [[6, 0, 0, "-", "analyticdb_spark"], [8, 0, 0, "-", "oss"]], "airflow.providers.alibaba.cloud.operators.analyticdb_spark": [[6, 2, 1, "", "AnalyticDBSparkBaseOperator"], [6, 2, 1, "", "AnalyticDBSparkBatchOperator"], [6, 2, 1, "", "AnalyticDBSparkSQLOperator"]], "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator": [[6, 4, 1, "", "execute"], [6, 4, 1, "", "get_hook"], [6, 4, 1, "", "hook"], [6, 4, 1, "", "kill"], [6, 4, 1, "", "monitor_application"], [6, 4, 1, "", "on_kill"], [6, 4, 1, "", "poll_for_termination"]], "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBatchOperator": [[6, 4, 1, "", "execute"], [6, 3, 1, "", "template_fields"], [6, 3, 1, "", "template_fields_renderers"]], "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkSQLOperator": [[6, 4, 1, "", "execute"], [6, 3, 1, "", "template_fields"], [6, 3, 1, "", "template_fields_renderers"]], "airflow.providers.alibaba.cloud.operators.oss": [[8, 2, 1, "", "OSSCreateBucketOperator"], [8, 2, 1, "", "OSSDeleteBatchObjectOperator"], [8, 2, 1, "", "OSSDeleteBucketOperator"], [8, 2, 1, "", "OSSDeleteObjectOperator"], [8, 2, 1, "", "OSSDownloadObjectOperator"], [8, 2, 1, "", "OSSUploadObjectOperator"]], "airflow.providers.alibaba.cloud.operators.oss.OSSCreateBucketOperator": [[8, 4, 1, "", "execute"]], "airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBatchObjectOperator": [[8, 4, 1, "", "execute"]], "airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBucketOperator": [[8, 4, 1, "", "execute"]], "airflow.providers.alibaba.cloud.operators.oss.OSSDeleteObjectOperator": [[8, 4, 1, "", "execute"]], "airflow.providers.alibaba.cloud.operators.oss.OSSDownloadObjectOperator": [[8, 4, 1, "", "execute"]], "airflow.providers.alibaba.cloud.operators.oss.OSSUploadObjectOperator": [[8, 4, 1, "", "execute"]], "airflow.providers.alibaba.cloud.sensors": [[9, 0, 0, "-", "analyticdb_spark"], [11, 0, 0, "-", "oss_key"]], "airflow.providers.alibaba.cloud.sensors.analyticdb_spark": [[9, 2, 1, "", "AnalyticDBSparkSensor"]], "airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor": [[9, 4, 1, "", "get_hook"], [9, 4, 1, "", "hook"], [9, 4, 1, "", "poke"], [9, 3, 1, "", "template_fields"]], "airflow.providers.alibaba.cloud.sensors.oss_key": [[11, 2, 1, "", "OSSKeySensor"]], "airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor": [[11, 6, 1, "", "get_hook"], [11, 4, 1, "", "hook"], [11, 4, 1, "", "poke"], [11, 3, 1, "", "template_fields"]], "tests.system.providers": [[17, 0, 0, "-", "alibaba"]], "tests.system.providers.alibaba": [[13, 0, 0, "-", "example_adb_spark_batch"], [14, 0, 0, "-", "example_adb_spark_sql"], [15, 0, 0, "-", "example_oss_bucket"], [16, 0, 0, "-", "example_oss_object"]], "tests.system.providers.alibaba.example_adb_spark_batch": [[13, 1, 1, "", "DAG_ID"], [13, 1, 1, "", "ENV_ID"], [13, 1, 1, "", "spark_pi"], [13, 1, 1, "", "test_run"]], "tests.system.providers.alibaba.example_adb_spark_sql": [[14, 1, 1, "", "DAG_ID"], [14, 1, 1, "", "ENV_ID"], [14, 1, 1, "", "show_databases"], [14, 1, 1, "", "test_run"]], "tests.system.providers.alibaba.example_oss_bucket": [[15, 1, 1, "", "DAG_ID"], [15, 1, 1, "", "ENV_ID"], [15, 1, 1, "", "REGION"], [15, 1, 1, "", "create_bucket"], [15, 1, 1, "", "test_run"]], "tests.system.providers.alibaba.example_oss_object": [[16, 1, 1, "", "DAG_ID"], [16, 1, 1, "", "ENV_ID"], [16, 1, 1, "", "create_object"], [16, 1, 1, "", "test_run"]]}, "objtypes": {"0": "py:module", "1": "py:data", "2": "py:class", "3": "py:attribute", "4": "py:method", "5": "py:function", "6": "py:property"}, "objnames": {"0": ["py", "module", "Python module"], "1": ["py", "data", "Python data"], "2": ["py", "class", "Python class"], "3": ["py", "attribute", "Python attribute"], "4": ["py", "method", "Python method"], "5": ["py", "function", "Python function"], "6": ["py", "property", "Python property"]}, "titleterms": {"airflow": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 19, 21], "provid": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 19, 21], "alibaba": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 19, 20, 21, 24, 25, 26, 27], "cloud": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 20, 25, 26, 27], "hook": [0, 1, 2], "analyticdb_spark": [0, 6, 9], "modul": [0, 2, 5, 6, 8, 9, 11, 13, 14, 15, 16], "content": [0, 2, 5, 6, 8, 9, 11, 12, 13, 14, 15, 16], "class": [0, 2, 5, 6, 8, 9, 11], "submodul": [1, 4, 7, 10, 17], "oss": [2, 8, 24, 27], "function": [2, 5], "attribut": 2, "subpackag": [3, 12], "log": [4, 5, 23, 24], "oss_task_handl": 5, "oper": [6, 7, 8, 25, 26, 27], "sensor": [9, 10, 11], "oss_kei": 11, "packag": [12, 19, 21, 22], "test": [13, 14, 15, 16, 17], "system": [13, 14, 15, 16, 17], "example_adb_spark_batch": 13, "example_adb_spark_sql": 14, "example_oss_bucket": 15, "example_oss_object": 16, "changelog": 18, "2": [18, 19], "7": [18, 19], "0": [18, 19], "misc": 18, "6": [18, 19], "5": [18, 19], "3": [18, 19], "bug": 18, "fix": 18, "1": [18, 19], "featur": 18, "4": [18, 19], "break": 18, "chang": 18, "apach": [19, 21], "connect": 20, "authent": 20, "default": 20, "id": 20, "configur": 20, "exampl": 20, "extra": 20, "field": 20, "instal": [21, 22], "requir": 21, "from": 22, "sourc": 22, "releas": [22, 28], "integr": 22, "verifi": 22, "pypi": 22, "task": [23, 25, 27], "write": 24, "enabl": 24, "remot": 24, "analyticdb": 25, "spark": 25, "overview": [25, 27], "develop": 25, "batch": 25, "applic": 25, "purpos": [25, 27], "defin": [25, 27], "creat": 27, "delet": 27, "bucket": 27, "secur": 28, "patch": 28}, "envversion": {"sphinx.domains.c": 2, "sphinx.domains.changeset": 1, "sphinx.domains.citation": 1, "sphinx.domains.cpp": 8, "sphinx.domains.index": 1, "sphinx.domains.javascript": 2, "sphinx.domains.math": 2, "sphinx.domains.python": 3, "sphinx.domains.rst": 2, "sphinx.domains.std": 2, "sphinx.ext.viewcode": 1, "sphinx.ext.intersphinx": 1, "sphinx": 57}, "alltitles": {"airflow.providers.alibaba.cloud.hooks.analyticdb_spark": [[0, "module-airflow.providers.alibaba.cloud.hooks.analyticdb_spark"]], "Module Contents": [[0, "module-contents"], [2, "module-contents"], [5, "module-contents"], [6, "module-contents"], [8, "module-contents"], [9, "module-contents"], [11, "module-contents"], [13, "module-contents"], [14, "module-contents"], [15, "module-contents"], [16, "module-contents"]], "Classes": [[0, "classes"], [2, "classes"], [5, "classes"], [6, "classes"], [8, "classes"], [9, "classes"], [11, "classes"]], "airflow.providers.alibaba.cloud.hooks": [[1, "module-airflow.providers.alibaba.cloud.hooks"]], "Submodules": [[1, "submodules"], [4, "submodules"], [7, "submodules"], [10, "submodules"], [17, "submodules"]], "airflow.providers.alibaba.cloud.hooks.oss": [[2, "module-airflow.providers.alibaba.cloud.hooks.oss"]], "Functions": [[2, "functions"], [5, "functions"]], "Attributes": [[2, "attributes"]], "airflow.providers.alibaba.cloud": [[3, "module-airflow.providers.alibaba.cloud"]], "Subpackages": [[3, "subpackages"], [12, "subpackages"]], "airflow.providers.alibaba.cloud.log": [[4, "module-airflow.providers.alibaba.cloud.log"]], "airflow.providers.alibaba.cloud.log.oss_task_handler": [[5, "module-airflow.providers.alibaba.cloud.log.oss_task_handler"]], "airflow.providers.alibaba.cloud.operators.analyticdb_spark": [[6, "module-airflow.providers.alibaba.cloud.operators.analyticdb_spark"]], "airflow.providers.alibaba.cloud.operators": [[7, "module-airflow.providers.alibaba.cloud.operators"]], "airflow.providers.alibaba.cloud.operators.oss": [[8, "module-airflow.providers.alibaba.cloud.operators.oss"]], "airflow.providers.alibaba.cloud.sensors.analyticdb_spark": [[9, "module-airflow.providers.alibaba.cloud.sensors.analyticdb_spark"]], "airflow.providers.alibaba.cloud.sensors": [[10, "module-airflow.providers.alibaba.cloud.sensors"]], "airflow.providers.alibaba.cloud.sensors.oss_key": [[11, "module-airflow.providers.alibaba.cloud.sensors.oss_key"]], "airflow.providers.alibaba": [[12, "module-airflow.providers.alibaba"]], "Package Contents": [[12, "package-contents"]], "tests.system.providers.alibaba.example_adb_spark_batch": [[13, "module-tests.system.providers.alibaba.example_adb_spark_batch"]], "tests.system.providers.alibaba.example_adb_spark_sql": [[14, "module-tests.system.providers.alibaba.example_adb_spark_sql"]], "tests.system.providers.alibaba.example_oss_bucket": [[15, "module-tests.system.providers.alibaba.example_oss_bucket"]], "tests.system.providers.alibaba.example_oss_object": [[16, "module-tests.system.providers.alibaba.example_oss_object"]], "tests.system.providers.alibaba": [[17, "module-tests.system.providers.alibaba"]], "Changelog": [[18, "changelog"]], "2.7.0": [[18, "id1"], [19, "id1"]], "Misc": [[18, "misc"], [18, "id4"], [18, "id7"], [18, "id9"], [18, "id12"], [18, "id15"], [18, "id20"], [18, "id28"], [18, "id33"], [18, "id35"]], "2.6.0": [[18, "id2"], [19, "id2"]], "2.5.3": [[18, "id5"], [19, "id3"]], "Bug Fixes": [[18, "bug-fixes"], [18, "id24"], [18, "id30"]], "2.5.2": [[18, "id6"], [19, "id4"]], "2.5.1": [[18, "id8"], [19, "id5"]], "2.5.0": [[18, "id10"], [19, "id6"]], "Features": [[18, "features"], [18, "id17"], [18, "id22"], [18, "id27"], [18, "id32"]], "2.4.1": [[18, "id11"], [19, "id7"]], "2.4.0": [[18, "id13"], [19, "id8"]], "2.3.0": [[18, "id16"], [19, "id9"]], "2.2.0": [[18, "id18"], [19, "id10"]], "2.1.0": [[18, "id21"], [19, "id11"]], "2.0.1": [[18, "id23"], [19, "id12"]], "2.0.0": [[18, "id25"], [19, "id13"]], "Breaking changes": [[18, "breaking-changes"]], "1.1.1": [[18, "id29"], [19, "id14"]], "1.1.0": [[18, "id31"], [19, "id15"]], "1.0.1": [[18, "id34"], [19, "id16"]], "1.0.0": [[18, "id36"], [19, "id18"]], "Package apache-airflow-providers-alibaba": [[19, "package-apache-airflow-providers-alibaba"], [21, "package-apache-airflow-providers-alibaba"]], "Alibaba Cloud Connection": [[20, "alibaba-cloud-connection"]], "Authenticating to Alibaba Cloud": [[20, "authenticating-to-alibaba-cloud"]], "Default Connection IDs": [[20, "default-connection-ids"]], "Configuring the Connection": [[20, "configuring-the-connection"]], "Examples for the Extra field": [[20, "examples-for-the-extra-field"]], "apache-airflow-providers-alibaba": [[21, "apache-airflow-providers-alibaba"]], "Provider package": [[21, "provider-package"]], "Installation": [[21, "installation"]], "Requirements": [[21, "requirements"]], "Installing from sources": [[22, "installing-from-sources"]], "Released packages": [[22, "released-packages"]], "Release integrity": [[22, "release-integrity"]], "Verifying PyPI releases": [[22, "verifying-pypi-releases"]], "Logging for Tasks": [[23, "logging-for-tasks"]], "Writing logs to Alibaba OSS": [[24, "writing-logs-to-alibaba-oss"]], "Enabling remote logging": [[24, "enabling-remote-logging"]], "Alibaba Cloud AnalyticDB Spark Operators": [[25, "alibaba-cloud-analyticdb-spark-operators"]], "Overview": [[25, "overview"], [27, "overview"]], "Develop Spark batch applications": [[25, "develop-spark-batch-applications"]], "Purpose": [[25, "purpose"], [27, "purpose"]], "Defining tasks": [[25, "defining-tasks"], [27, "defining-tasks"]], "Alibaba Cloud Operators": [[26, "alibaba-cloud-operators"]], "Alibaba Cloud OSS Operators": [[27, "alibaba-cloud-oss-operators"]], "Create and Delete Alibaba Cloud OSS Buckets": [[27, "create-and-delete-alibaba-cloud-oss-buckets"]], "Releasing security patches": [[28, "releasing-security-patches"]]}, "indexentries": {"analyticdbsparkhook (class in airflow.providers.alibaba.cloud.hooks.analyticdb_spark)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook"]], "appstate (class in airflow.providers.alibaba.cloud.hooks.analyticdb_spark)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState"]], "completed (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.appstate attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState.COMPLETED"]], "failed (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.appstate attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState.FAILED"]], "failing (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.appstate attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState.FAILING"]], "fatal (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.appstate attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState.FATAL"]], "killed (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.appstate attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState.KILLED"]], "killing (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.appstate attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState.KILLING"]], "running (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.appstate attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState.RUNNING"]], "starting (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.appstate attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState.STARTING"]], "submitted (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.appstate attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState.SUBMITTED"]], "succeeding (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.appstate attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState.SUCCEEDING"]], "terminal_states (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.TERMINAL_STATES"]], "unknown (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.appstate attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AppState.UNKNOWN"]], "airflow.providers.alibaba.cloud.hooks.analyticdb_spark": [[0, "module-airflow.providers.alibaba.cloud.hooks.analyticdb_spark"]], "build_submit_app_data() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook static method)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.build_submit_app_data"]], "build_submit_sql_data() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook static method)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.build_submit_sql_data"]], "conn_name_attr (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.conn_name_attr"]], "conn_type (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.conn_type"]], "default_conn_name (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.default_conn_name"]], "get_adb_spark_client() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook method)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.get_adb_spark_client"]], "get_default_region() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook method)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.get_default_region"]], "get_spark_log() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook method)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.get_spark_log"]], "get_spark_state() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook method)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.get_spark_state"]], "get_spark_web_ui_address() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook method)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.get_spark_web_ui_address"]], "hook_name (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook attribute)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.hook_name"]], "kill_spark_app() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook method)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.kill_spark_app"]], "module": [[0, "module-airflow.providers.alibaba.cloud.hooks.analyticdb_spark"], [1, "module-airflow.providers.alibaba.cloud.hooks"], [2, "module-airflow.providers.alibaba.cloud.hooks.oss"], [3, "module-airflow.providers.alibaba.cloud"], [4, "module-airflow.providers.alibaba.cloud.log"], [5, "module-airflow.providers.alibaba.cloud.log.oss_task_handler"], [6, "module-airflow.providers.alibaba.cloud.operators.analyticdb_spark"], [7, "module-airflow.providers.alibaba.cloud.operators"], [8, "module-airflow.providers.alibaba.cloud.operators.oss"], [9, "module-airflow.providers.alibaba.cloud.sensors.analyticdb_spark"], [10, "module-airflow.providers.alibaba.cloud.sensors"], [11, "module-airflow.providers.alibaba.cloud.sensors.oss_key"], [12, "module-airflow.providers.alibaba"], [13, "module-tests.system.providers.alibaba.example_adb_spark_batch"], [14, "module-tests.system.providers.alibaba.example_adb_spark_sql"], [15, "module-tests.system.providers.alibaba.example_oss_bucket"], [16, "module-tests.system.providers.alibaba.example_oss_object"], [17, "module-tests.system.providers.alibaba"]], "submit_spark_app() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook method)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.submit_spark_app"]], "submit_spark_sql() (airflow.providers.alibaba.cloud.hooks.analyticdb_spark.analyticdbsparkhook method)": [[0, "airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook.submit_spark_sql"]], "airflow.providers.alibaba.cloud.hooks": [[1, "module-airflow.providers.alibaba.cloud.hooks"]], "osshook (class in airflow.providers.alibaba.cloud.hooks.oss)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook"]], "t (in module airflow.providers.alibaba.cloud.hooks.oss)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.T"]], "airflow.providers.alibaba.cloud.hooks.oss": [[2, "module-airflow.providers.alibaba.cloud.hooks.oss"]], "append_string() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.append_string"]], "conn_name_attr (airflow.providers.alibaba.cloud.hooks.oss.osshook attribute)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.conn_name_attr"]], "conn_type (airflow.providers.alibaba.cloud.hooks.oss.osshook attribute)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.conn_type"]], "create_bucket() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.create_bucket"]], "default_conn_name (airflow.providers.alibaba.cloud.hooks.oss.osshook attribute)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.default_conn_name"]], "delete_bucket() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.delete_bucket"]], "delete_object() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.delete_object"]], "delete_objects() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.delete_objects"]], "download_file() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.download_file"]], "get_bucket() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.get_bucket"]], "get_conn() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.get_conn"]], "get_credential() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.get_credential"]], "get_default_region() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.get_default_region"]], "head_key() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.head_key"]], "hook_name (airflow.providers.alibaba.cloud.hooks.oss.osshook attribute)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.hook_name"]], "key_exist() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.key_exist"]], "load_string() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.load_string"]], "object_exists() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.object_exists"]], "parse_oss_url() (airflow.providers.alibaba.cloud.hooks.oss.osshook static method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.parse_oss_url"]], "provide_bucket_name() (in module airflow.providers.alibaba.cloud.hooks.oss)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.provide_bucket_name"]], "read_key() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.read_key"]], "unify_bucket_name_and_key() (in module airflow.providers.alibaba.cloud.hooks.oss)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.unify_bucket_name_and_key"]], "upload_local_file() (airflow.providers.alibaba.cloud.hooks.oss.osshook method)": [[2, "airflow.providers.alibaba.cloud.hooks.oss.OSSHook.upload_local_file"]], "airflow.providers.alibaba.cloud": [[3, "module-airflow.providers.alibaba.cloud"]], "airflow.providers.alibaba.cloud.log": [[4, "module-airflow.providers.alibaba.cloud.log"]], "osstaskhandler (class in airflow.providers.alibaba.cloud.log.oss_task_handler)": [[5, "airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler"]], "airflow.providers.alibaba.cloud.log.oss_task_handler": [[5, "module-airflow.providers.alibaba.cloud.log.oss_task_handler"]], "close() (airflow.providers.alibaba.cloud.log.oss_task_handler.osstaskhandler method)": [[5, "airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler.close"]], "get_default_delete_local_copy() (in module airflow.providers.alibaba.cloud.log.oss_task_handler)": [[5, "airflow.providers.alibaba.cloud.log.oss_task_handler.get_default_delete_local_copy"]], "hook() (airflow.providers.alibaba.cloud.log.oss_task_handler.osstaskhandler method)": [[5, "airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler.hook"]], "oss_log_exists() (airflow.providers.alibaba.cloud.log.oss_task_handler.osstaskhandler method)": [[5, "airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler.oss_log_exists"]], "oss_read() (airflow.providers.alibaba.cloud.log.oss_task_handler.osstaskhandler method)": [[5, "airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler.oss_read"]], "oss_write() (airflow.providers.alibaba.cloud.log.oss_task_handler.osstaskhandler method)": [[5, "airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler.oss_write"]], "set_context() (airflow.providers.alibaba.cloud.log.oss_task_handler.osstaskhandler method)": [[5, "airflow.providers.alibaba.cloud.log.oss_task_handler.OSSTaskHandler.set_context"]], "analyticdbsparkbaseoperator (class in airflow.providers.alibaba.cloud.operators.analyticdb_spark)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator"]], "analyticdbsparkbatchoperator (class in airflow.providers.alibaba.cloud.operators.analyticdb_spark)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBatchOperator"]], "analyticdbsparksqloperator (class in airflow.providers.alibaba.cloud.operators.analyticdb_spark)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkSQLOperator"]], "airflow.providers.alibaba.cloud.operators.analyticdb_spark": [[6, "module-airflow.providers.alibaba.cloud.operators.analyticdb_spark"]], "execute() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparkbaseoperator method)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator.execute"]], "execute() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparkbatchoperator method)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBatchOperator.execute"]], "execute() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparksqloperator method)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkSQLOperator.execute"]], "get_hook() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparkbaseoperator method)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator.get_hook"]], "hook() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparkbaseoperator method)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator.hook"]], "kill() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparkbaseoperator method)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator.kill"]], "monitor_application() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparkbaseoperator method)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator.monitor_application"]], "on_kill() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparkbaseoperator method)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator.on_kill"]], "poll_for_termination() (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparkbaseoperator method)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBaseOperator.poll_for_termination"]], "template_fields (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparkbatchoperator attribute)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBatchOperator.template_fields"]], "template_fields (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparksqloperator attribute)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkSQLOperator.template_fields"]], "template_fields_renderers (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparkbatchoperator attribute)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkBatchOperator.template_fields_renderers"]], "template_fields_renderers (airflow.providers.alibaba.cloud.operators.analyticdb_spark.analyticdbsparksqloperator attribute)": [[6, "airflow.providers.alibaba.cloud.operators.analyticdb_spark.AnalyticDBSparkSQLOperator.template_fields_renderers"]], "airflow.providers.alibaba.cloud.operators": [[7, "module-airflow.providers.alibaba.cloud.operators"]], "osscreatebucketoperator (class in airflow.providers.alibaba.cloud.operators.oss)": [[8, "airflow.providers.alibaba.cloud.operators.oss.OSSCreateBucketOperator"]], "ossdeletebatchobjectoperator (class in airflow.providers.alibaba.cloud.operators.oss)": [[8, "airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBatchObjectOperator"]], "ossdeletebucketoperator (class in airflow.providers.alibaba.cloud.operators.oss)": [[8, "airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBucketOperator"]], "ossdeleteobjectoperator (class in airflow.providers.alibaba.cloud.operators.oss)": [[8, "airflow.providers.alibaba.cloud.operators.oss.OSSDeleteObjectOperator"]], "ossdownloadobjectoperator (class in airflow.providers.alibaba.cloud.operators.oss)": [[8, "airflow.providers.alibaba.cloud.operators.oss.OSSDownloadObjectOperator"]], "ossuploadobjectoperator (class in airflow.providers.alibaba.cloud.operators.oss)": [[8, "airflow.providers.alibaba.cloud.operators.oss.OSSUploadObjectOperator"]], "airflow.providers.alibaba.cloud.operators.oss": [[8, "module-airflow.providers.alibaba.cloud.operators.oss"]], "execute() (airflow.providers.alibaba.cloud.operators.oss.osscreatebucketoperator method)": [[8, "airflow.providers.alibaba.cloud.operators.oss.OSSCreateBucketOperator.execute"]], "execute() (airflow.providers.alibaba.cloud.operators.oss.ossdeletebatchobjectoperator method)": [[8, "airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBatchObjectOperator.execute"]], "execute() (airflow.providers.alibaba.cloud.operators.oss.ossdeletebucketoperator method)": [[8, "airflow.providers.alibaba.cloud.operators.oss.OSSDeleteBucketOperator.execute"]], "execute() (airflow.providers.alibaba.cloud.operators.oss.ossdeleteobjectoperator method)": [[8, "airflow.providers.alibaba.cloud.operators.oss.OSSDeleteObjectOperator.execute"]], "execute() (airflow.providers.alibaba.cloud.operators.oss.ossdownloadobjectoperator method)": [[8, "airflow.providers.alibaba.cloud.operators.oss.OSSDownloadObjectOperator.execute"]], "execute() (airflow.providers.alibaba.cloud.operators.oss.ossuploadobjectoperator method)": [[8, "airflow.providers.alibaba.cloud.operators.oss.OSSUploadObjectOperator.execute"]], "analyticdbsparksensor (class in airflow.providers.alibaba.cloud.sensors.analyticdb_spark)": [[9, "airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor"]], "airflow.providers.alibaba.cloud.sensors.analyticdb_spark": [[9, "module-airflow.providers.alibaba.cloud.sensors.analyticdb_spark"]], "get_hook() (airflow.providers.alibaba.cloud.sensors.analyticdb_spark.analyticdbsparksensor method)": [[9, "airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor.get_hook"]], "hook() (airflow.providers.alibaba.cloud.sensors.analyticdb_spark.analyticdbsparksensor method)": [[9, "airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor.hook"]], "poke() (airflow.providers.alibaba.cloud.sensors.analyticdb_spark.analyticdbsparksensor method)": [[9, "airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor.poke"]], "template_fields (airflow.providers.alibaba.cloud.sensors.analyticdb_spark.analyticdbsparksensor attribute)": [[9, "airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor.template_fields"]], "airflow.providers.alibaba.cloud.sensors": [[10, "module-airflow.providers.alibaba.cloud.sensors"]], "osskeysensor (class in airflow.providers.alibaba.cloud.sensors.oss_key)": [[11, "airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor"]], "airflow.providers.alibaba.cloud.sensors.oss_key": [[11, "module-airflow.providers.alibaba.cloud.sensors.oss_key"]], "get_hook (airflow.providers.alibaba.cloud.sensors.oss_key.osskeysensor property)": [[11, "airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor.get_hook"]], "hook() (airflow.providers.alibaba.cloud.sensors.oss_key.osskeysensor method)": [[11, "airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor.hook"]], "poke() (airflow.providers.alibaba.cloud.sensors.oss_key.osskeysensor method)": [[11, "airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor.poke"]], "template_fields (airflow.providers.alibaba.cloud.sensors.oss_key.osskeysensor attribute)": [[11, "airflow.providers.alibaba.cloud.sensors.oss_key.OSSKeySensor.template_fields"]], "__version__ (in module airflow.providers.alibaba)": [[12, "airflow.providers.alibaba.__version__"]], "airflow.providers.alibaba": [[12, "module-airflow.providers.alibaba"]], "dag_id (in module tests.system.providers.alibaba.example_adb_spark_batch)": [[13, "tests.system.providers.alibaba.example_adb_spark_batch.DAG_ID"]], "env_id (in module tests.system.providers.alibaba.example_adb_spark_batch)": [[13, "tests.system.providers.alibaba.example_adb_spark_batch.ENV_ID"]], "spark_pi (in module tests.system.providers.alibaba.example_adb_spark_batch)": [[13, "tests.system.providers.alibaba.example_adb_spark_batch.spark_pi"]], "test_run (in module tests.system.providers.alibaba.example_adb_spark_batch)": [[13, "tests.system.providers.alibaba.example_adb_spark_batch.test_run"]], "tests.system.providers.alibaba.example_adb_spark_batch": [[13, "module-tests.system.providers.alibaba.example_adb_spark_batch"]], "dag_id (in module tests.system.providers.alibaba.example_adb_spark_sql)": [[14, "tests.system.providers.alibaba.example_adb_spark_sql.DAG_ID"]], "env_id (in module tests.system.providers.alibaba.example_adb_spark_sql)": [[14, "tests.system.providers.alibaba.example_adb_spark_sql.ENV_ID"]], "show_databases (in module tests.system.providers.alibaba.example_adb_spark_sql)": [[14, "tests.system.providers.alibaba.example_adb_spark_sql.show_databases"]], "test_run (in module tests.system.providers.alibaba.example_adb_spark_sql)": [[14, "tests.system.providers.alibaba.example_adb_spark_sql.test_run"]], "tests.system.providers.alibaba.example_adb_spark_sql": [[14, "module-tests.system.providers.alibaba.example_adb_spark_sql"]], "dag_id (in module tests.system.providers.alibaba.example_oss_bucket)": [[15, "tests.system.providers.alibaba.example_oss_bucket.DAG_ID"]], "env_id (in module tests.system.providers.alibaba.example_oss_bucket)": [[15, "tests.system.providers.alibaba.example_oss_bucket.ENV_ID"]], "region (in module tests.system.providers.alibaba.example_oss_bucket)": [[15, "tests.system.providers.alibaba.example_oss_bucket.REGION"]], "create_bucket (in module tests.system.providers.alibaba.example_oss_bucket)": [[15, "tests.system.providers.alibaba.example_oss_bucket.create_bucket"]], "test_run (in module tests.system.providers.alibaba.example_oss_bucket)": [[15, "tests.system.providers.alibaba.example_oss_bucket.test_run"]], "tests.system.providers.alibaba.example_oss_bucket": [[15, "module-tests.system.providers.alibaba.example_oss_bucket"]], "dag_id (in module tests.system.providers.alibaba.example_oss_object)": [[16, "tests.system.providers.alibaba.example_oss_object.DAG_ID"]], "env_id (in module tests.system.providers.alibaba.example_oss_object)": [[16, "tests.system.providers.alibaba.example_oss_object.ENV_ID"]], "create_object (in module tests.system.providers.alibaba.example_oss_object)": [[16, "tests.system.providers.alibaba.example_oss_object.create_object"]], "test_run (in module tests.system.providers.alibaba.example_oss_object)": [[16, "tests.system.providers.alibaba.example_oss_object.test_run"]], "tests.system.providers.alibaba.example_oss_object": [[16, "module-tests.system.providers.alibaba.example_oss_object"]], "tests.system.providers.alibaba": [[17, "module-tests.system.providers.alibaba"]]}}) |