| Search.setIndex({"alltitles": {"1.0.0": [[11, "id134"], [12, "id55"]], "1.0.1": [[11, "id132"], [12, "id54"]], "1.0.2": [[11, "id130"], [12, "id53"]], "1.0.3": [[11, "id128"], [12, "id52"]], "1.0.4": [[11, "id126"], [12, "id51"]], "2.0.0 (YANKED)": [[11, "id125"]], "2.0.1": [[11, "id121"], [12, "id50"]], "2.0.2": [[11, "id119"], [12, "id49"]], "2.0.3": [[11, "id116"], [12, "id48"]], "2.1.0": [[11, "id114"], [12, "id47"]], "2.2.0": [[11, "id111"], [12, "id46"]], "3.0.0": [[12, "id45"]], "3.0.0 (YANKED)": [[11, "id108"]], "3.0.1": [[12, "id44"]], "3.0.1 (YANKED)": [[11, "id106"]], "3.0.2": [[12, "id43"]], "3.0.2 (YANKED)": [[11, "yanked"]], "3.0.3": [[11, "id103"], [12, "id42"]], "4.0.0": [[11, "id99"], [12, "id41"]], "4.1.0": [[11, "id96"], [12, "id40"]], "4.2.0": [[11, "id94"], [12, "id39"]], "4.2.1": [[11, "id92"], [12, "id38"]], "4.3.0": [[11, "id89"], [12, "id37"]], "4.3.1": [[11, "id87"], [12, "id36"]], "4.3.2": [[11, "id85"], [12, "id35"]], "4.3.3": [[11, "id83"], [12, "id34"]], "4.4.0": [[11, "id81"], [12, "id33"]], "4.5.0": [[11, "id78"], [12, "id32"]], "4.5.1": [[11, "id76"], [12, "id31"]], "5.0.0": [[11, "id72"], [12, "id30"]], "5.0.1": [[11, "id69"], [12, "id29"]], "5.0.2": [[11, "id66"], [12, "id28"]], "5.1.0": [[11, "id63"], [12, "id27"]], "5.1.1": [[11, "id61"], [12, "id26"]], "5.2.0": [[11, "id57"], [12, "id25"]], "5.3.0": [[11, "id54"], [12, "id24"]], "5.3.1": [[11, "id52"], [12, "id23"]], "5.3.2": [[11, "id50"], [12, "id22"]], "5.3.3": [[11, "id48"], [12, "id21"]], "5.3.4": [[11, "id46"], [12, "id20"]], "5.4.0": [[11, "id43"], [12, "id19"]], "5.4.1": [[11, "id40"], [12, "id18"]], "5.4.2": [[11, "id38"], [12, "id17"]], "5.5.0": [[11, "id34"], [12, "id16"]], "5.5.1": [[11, "id31"], [12, "id15"]], "5.5.2": [[11, "id29"], [12, "id14"]], "5.5.3": [[11, "id27"], [12, "id13"]], "6.0.0": [[11, "id25"], [12, "id12"]], "6.1.0": [[11, "id23"]], "6.2.0": [[11, "id22"], [12, "id11"]], "6.2.1": [[11, "id20"], [12, "id10"]], "6.2.2": [[11, "id17"], [12, "id9"]], "6.3.0": [[11, "id15"], [12, "id8"]], "6.3.1": [[11, "id13"], [12, "id7"]], "6.3.2": [[11, "id10"], [12, "id6"]], "6.3.3": [[11, "id8"], [12, "id5"]], "6.3.4": [[11, "id6"], [12, "id4"]], "6.3.5": [[11, "id4"], [12, "id3"]], "6.4.0": [[11, "id2"], [12, "id2"]], "6.4.1": [[11, "id1"], [12, "id1"]], "Attributes": [[3, "attributes"], [6, "attributes"], [8, "attributes"], [9, "attributes"]], "Authenticating to ElasticSearch": [[14, "authenticating-to-elasticsearch"]], "Breaking changes": [[11, "breaking-changes"], [11, "id73"], [11, "id100"], [11, "id109"], [11, "id122"]], "Bug Fixes": [[11, "bug-fixes"], [11, "id11"], [11, "id18"], [11, "id32"], [11, "id36"], [11, "id41"], [11, "id51"], [11, "id59"], [11, "id67"], [11, "id70"], [11, "id74"], [11, "id84"], [11, "id86"], [11, "id88"], [11, "id98"], [11, "id104"], [11, "id105"], [11, "id117"], [11, "id120"]], "Bug fixes": [[11, "id124"], [11, "id127"], [11, "id129"], [11, "id131"], [11, "id133"]], "Changelog": [[11, null]], "Changes to [elasticsearch] log_id_template": [[20, "changes-to-elasticsearch-log-id-template"]], "Classes": [[1, "classes"], [4, "classes"], [5, "classes"], [6, "classes"]], "Configuration Reference": [[13, null]], "Configuring the Connection": [[14, "configuring-the-connection"]], "Cross provider package dependencies": [[18, "cross-provider-package-dependencies"]], "Default Connection IDs": [[14, "default-connection-ids"]], "Doc-only": [[11, "doc-only"], [11, "id9"]], "Downloading official packages": [[18, "downloading-official-packages"]], "ElasticSearch Connection": [[14, null]], "Elasticsearch External Link": [[20, "elasticsearch-external-link"]], "ElasticsearchPythonHook": [[15, null]], "ElasticsearchSQLHook": [[16, null]], "Features": [[11, "features"], [11, "id58"], [11, "id82"], [11, "id95"], [11, "id97"], [11, "id112"], [11, "id115"], [11, "id123"]], "Functions": [[0, "functions"], [1, "functions"], [6, "functions"], [9, "functions"]], "Hook Types": [[17, null]], "Installation": [[18, "installation"]], "Installing from sources": [[19, null]], "Misc": [[11, "misc"], [11, "id3"], [11, "id5"], [11, "id7"], [11, "id12"], [11, "id14"], [11, "id16"], [11, "id19"], [11, "id21"], [11, "id24"], [11, "id26"], [11, "id28"], [11, "id30"], [11, "id33"], [11, "id37"], [11, "id39"], [11, "id42"], [11, "id45"], [11, "id47"], [11, "id49"], [11, "id53"], [11, "id56"], [11, "id60"], [11, "id62"], [11, "id65"], [11, "id68"], [11, "id71"], [11, "id75"], [11, "id77"], [11, "id80"], [11, "id91"], [11, "id93"], [11, "id102"], [11, "id107"], [11, "id110"], [11, "id113"], [11, "id118"]], "Module Contents": [[0, "module-contents"], [1, "module-contents"], [4, "module-contents"], [5, "module-contents"], [6, "module-contents"], [8, "module-contents"], [9, "module-contents"]], "Package Contents": [[3, "package-contents"]], "Package apache-airflow-providers-elasticsearch": [[12, null]], "Parameters": [[15, "parameters"]], "Provider package": [[18, "provider-package"]], "Release integrity": [[19, "release-integrity"]], "Released packages": [[19, "released-packages"]], "Releasing security patches": [[21, null]], "Requirements": [[18, "requirements"]], "Sections:": [[13, "sections"]], "Submodules": [[2, "submodules"], [3, "submodules"], [7, "submodules"], [10, "submodules"]], "Usage Example": [[15, "usage-example"], [16, "usage-example"]], "Verifying PyPI releases": [[19, "verifying-pypi-releases"]], "Writing logs to Elasticsearch": [[20, null]], "Writing logs to Elasticsearch over TLS": [[20, "writing-logs-to-elasticsearch-over-tls"]], "[elasticsearch]": [[13, "elasticsearch"]], "[elasticsearch_configs]": [[13, "elasticsearch-configs"]], "airflow.providers.elasticsearch": [[3, null]], "airflow.providers.elasticsearch.get_provider_info": [[0, null]], "airflow.providers.elasticsearch.hooks": [[2, null]], "airflow.providers.elasticsearch.hooks.elasticsearch": [[1, null]], "airflow.providers.elasticsearch.log": [[7, null]], "airflow.providers.elasticsearch.log.es_json_formatter": [[4, null]], "airflow.providers.elasticsearch.log.es_response": [[5, null]], "airflow.providers.elasticsearch.log.es_task_handler": [[6, null]], "airflow.providers.elasticsearch.version_compat": [[8, null]], "apache-airflow-providers-elasticsearch": [[18, null]], "apache-airflow-providers-elasticsearch package": [[18, "apache-airflow-providers-elasticsearch-package"]], "end_of_log_mark": [[13, "end-of-log-mark"]], "frontend": [[13, "frontend"]], "host": [[13, "host"]], "host_field": [[13, "host-field"]], "http_compress": [[13, "http-compress"]], "index_patterns": [[13, "index-patterns"]], "index_patterns_callable": [[13, "index-patterns-callable"]], "json_fields": [[13, "json-fields"]], "json_format": [[13, "json-format"]], "log_id_template": [[13, "log-id-template"]], "offset_field": [[13, "offset-field"]], "target_index": [[13, "target-index"]], "tests.system.elasticsearch": [[10, null]], "tests.system.elasticsearch.example_elasticsearch_query": [[9, null]], "verify_certs": [[13, "verify-certs"]], "write_stdout": [[13, "write-stdout"]], "write_to_es": [[13, "write-to-es"]]}, "docnames": ["_api/airflow/providers/elasticsearch/get_provider_info/index", "_api/airflow/providers/elasticsearch/hooks/elasticsearch/index", "_api/airflow/providers/elasticsearch/hooks/index", "_api/airflow/providers/elasticsearch/index", "_api/airflow/providers/elasticsearch/log/es_json_formatter/index", "_api/airflow/providers/elasticsearch/log/es_response/index", "_api/airflow/providers/elasticsearch/log/es_task_handler/index", "_api/airflow/providers/elasticsearch/log/index", "_api/airflow/providers/elasticsearch/version_compat/index", "_api/tests/system/elasticsearch/example_elasticsearch_query/index", "_api/tests/system/elasticsearch/index", "changelog", "commits", "configurations-ref", "connections/elasticsearch", "hooks/elasticsearch_python_hook", "hooks/elasticsearch_sql_hook", "hooks/index", "index", "installing-providers-from-sources", "logging/index", "security"], "envversion": {"sphinx": 64, "sphinx.domains.c": 3, "sphinx.domains.changeset": 1, "sphinx.domains.citation": 1, "sphinx.domains.cpp": 9, "sphinx.domains.index": 1, "sphinx.domains.javascript": 3, "sphinx.domains.math": 2, "sphinx.domains.python": 4, "sphinx.domains.rst": 2, "sphinx.domains.std": 2, "sphinx.ext.intersphinx": 1, "sphinx.ext.viewcode": 1}, "filenames": ["_api/airflow/providers/elasticsearch/get_provider_info/index.rst", "_api/airflow/providers/elasticsearch/hooks/elasticsearch/index.rst", "_api/airflow/providers/elasticsearch/hooks/index.rst", "_api/airflow/providers/elasticsearch/index.rst", "_api/airflow/providers/elasticsearch/log/es_json_formatter/index.rst", "_api/airflow/providers/elasticsearch/log/es_response/index.rst", "_api/airflow/providers/elasticsearch/log/es_task_handler/index.rst", "_api/airflow/providers/elasticsearch/log/index.rst", "_api/airflow/providers/elasticsearch/version_compat/index.rst", "_api/tests/system/elasticsearch/example_elasticsearch_query/index.rst", "_api/tests/system/elasticsearch/index.rst", "changelog.rst", "commits.rst", "configurations-ref.rst", "connections/elasticsearch.rst", "hooks/elasticsearch_python_hook.rst", "hooks/elasticsearch_sql_hook.rst", "hooks/index.rst", "index.rst", "installing-providers-from-sources.rst", "logging/index.rst", "security.rst"], "indexentries": {"__bool__() (airflow.providers.elasticsearch.log.es_response.attributelist method)": [[5, "airflow.providers.elasticsearch.log.es_response.AttributeList.__bool__", false]], "__bool__() (airflow.providers.elasticsearch.log.es_response.elasticsearchresponse method)": [[5, "airflow.providers.elasticsearch.log.es_response.ElasticSearchResponse.__bool__", false]], "__getattr__() (airflow.providers.elasticsearch.log.es_response.attributedict method)": [[5, "airflow.providers.elasticsearch.log.es_response.AttributeDict.__getattr__", false]], "__getitem__() (airflow.providers.elasticsearch.log.es_response.attributedict method)": [[5, "airflow.providers.elasticsearch.log.es_response.AttributeDict.__getitem__", false]], "__getitem__() (airflow.providers.elasticsearch.log.es_response.attributelist method)": [[5, "airflow.providers.elasticsearch.log.es_response.AttributeList.__getitem__", false]], "__getitem__() (airflow.providers.elasticsearch.log.es_response.elasticsearchresponse method)": [[5, "airflow.providers.elasticsearch.log.es_response.ElasticSearchResponse.__getitem__", false]], "__iter__() (airflow.providers.elasticsearch.log.es_response.attributelist method)": [[5, "airflow.providers.elasticsearch.log.es_response.AttributeList.__iter__", false]], "__iter__() (airflow.providers.elasticsearch.log.es_response.elasticsearchresponse method)": [[5, "airflow.providers.elasticsearch.log.es_response.ElasticSearchResponse.__iter__", false]], "__version__ (in module airflow.providers.elasticsearch)": [[3, "airflow.providers.elasticsearch.__version__", false]], "airflow.providers.elasticsearch": [[3, "module-airflow.providers.elasticsearch", false]], "airflow.providers.elasticsearch.get_provider_info": [[0, "module-airflow.providers.elasticsearch.get_provider_info", false]], "airflow.providers.elasticsearch.hooks": [[2, "module-airflow.providers.elasticsearch.hooks", false]], "airflow.providers.elasticsearch.hooks.elasticsearch": [[1, "module-airflow.providers.elasticsearch.hooks.elasticsearch", false]], "airflow.providers.elasticsearch.log": [[7, "module-airflow.providers.elasticsearch.log", false]], "airflow.providers.elasticsearch.log.es_json_formatter": [[4, "module-airflow.providers.elasticsearch.log.es_json_formatter", false]], "airflow.providers.elasticsearch.log.es_response": [[5, "module-airflow.providers.elasticsearch.log.es_response", false]], "airflow.providers.elasticsearch.log.es_task_handler": [[6, "module-airflow.providers.elasticsearch.log.es_task_handler", false]], "airflow.providers.elasticsearch.version_compat": [[8, "module-airflow.providers.elasticsearch.version_compat", false]], "airflow_v_3_0_plus (in module airflow.providers.elasticsearch.version_compat)": [[8, "airflow.providers.elasticsearch.version_compat.AIRFLOW_V_3_0_PLUS", false]], "airflow_v_3_1_plus (in module airflow.providers.elasticsearch.version_compat)": [[8, "airflow.providers.elasticsearch.version_compat.AIRFLOW_V_3_1_PLUS", false]], "attributedict (class in airflow.providers.elasticsearch.log.es_response)": [[5, "airflow.providers.elasticsearch.log.es_response.AttributeDict", false]], "attributelist (class in airflow.providers.elasticsearch.log.es_response)": [[5, "airflow.providers.elasticsearch.log.es_response.AttributeList", false]], "body (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlcursor attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor.body", false]], "client (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.client", false]], "close() (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlcursor method)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor.close", false]], "close() (airflow.providers.elasticsearch.hooks.elasticsearch.esconnection method)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection.close", false]], "close() (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler method)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.close", false]], "closed (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.closed", false]], "commit() (airflow.providers.elasticsearch.hooks.elasticsearch.esconnection method)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection.commit", false]], "conn_id (in module tests.system.elasticsearch.example_elasticsearch_query)": [[9, "tests.system.elasticsearch.example_elasticsearch_query.CONN_ID", false]], "conn_name_attr (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlhook attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLHook.conn_name_attr", false]], "conn_type (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlhook attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLHook.conn_type", false]], "connect() (in module airflow.providers.elasticsearch.hooks.elasticsearch)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.connect", false]], "connector (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlhook attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLHook.connector", false]], "context_set (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.context_set", false]], "cursor (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlcursor property)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor.cursor", false]], "cursor() (airflow.providers.elasticsearch.hooks.elasticsearch.esconnection method)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection.cursor", false]], "dag_id (in module tests.system.elasticsearch.example_elasticsearch_query)": [[9, "tests.system.elasticsearch.example_elasticsearch_query.DAG_ID", false]], "default_conn_name (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlhook attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLHook.default_conn_name", false]], "default_msec_format (airflow.providers.elasticsearch.log.es_json_formatter.elasticsearchjsonformatter attribute)": [[4, "airflow.providers.elasticsearch.log.es_json_formatter.ElasticsearchJSONFormatter.default_msec_format", false]], "default_time_format (airflow.providers.elasticsearch.log.es_json_formatter.elasticsearchjsonformatter attribute)": [[4, "airflow.providers.elasticsearch.log.es_json_formatter.ElasticsearchJSONFormatter.default_time_format", false]], "default_tz_format (airflow.providers.elasticsearch.log.es_json_formatter.elasticsearchjsonformatter attribute)": [[4, "airflow.providers.elasticsearch.log.es_json_formatter.ElasticsearchJSONFormatter.default_tz_format", false]], "delete_local_copy (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.delete_local_copy", false]], "description (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlcursor property)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor.description", false]], "elasticsearchjsonformatter (class in airflow.providers.elasticsearch.log.es_json_formatter)": [[4, "airflow.providers.elasticsearch.log.es_json_formatter.ElasticsearchJSONFormatter", false]], "elasticsearchpythonhook (class in airflow.providers.elasticsearch.hooks.elasticsearch)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchPythonHook", false]], "elasticsearchresponse (class in airflow.providers.elasticsearch.log.es_response)": [[5, "airflow.providers.elasticsearch.log.es_response.ElasticSearchResponse", false]], "elasticsearchsqlcursor (class in airflow.providers.elasticsearch.hooks.elasticsearch)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor", false]], "elasticsearchsqlhook (class in airflow.providers.elasticsearch.hooks.elasticsearch)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLHook", false]], "elasticsearchtaskhandler (class in airflow.providers.elasticsearch.log.es_task_handler)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler", false]], "emit() (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler method)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.emit", false]], "end_of_log_mark (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.end_of_log_mark", false]], "env_id (in module tests.system.elasticsearch.example_elasticsearch_query)": [[9, "tests.system.elasticsearch.example_elasticsearch_query.ENV_ID", false]], "es (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlcursor attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor.es", false]], "es_conn_args (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchpythonhook attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchPythonHook.es_conn_args", false]], "esconnection (class in airflow.providers.elasticsearch.hooks.elasticsearch)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection", false]], "eslogmsgtype (in module airflow.providers.elasticsearch.log.es_task_handler)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.EsLogMsgType", false]], "execute() (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlcursor method)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor.execute", false]], "execute_query (in module tests.system.elasticsearch.example_elasticsearch_query)": [[9, "tests.system.elasticsearch.example_elasticsearch_query.execute_query", false]], "execute_sql() (airflow.providers.elasticsearch.hooks.elasticsearch.esconnection method)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection.execute_sql", false]], "fetchall() (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlcursor method)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor.fetchall", false]], "fetchmany() (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlcursor method)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor.fetchmany", false]], "fetchone() (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlcursor method)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor.fetchone", false]], "format_url() (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler static method)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.format_url", false]], "formatter (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.formatter", false]], "formattime() (airflow.providers.elasticsearch.log.es_json_formatter.elasticsearchjsonformatter method)": [[4, "airflow.providers.elasticsearch.log.es_json_formatter.ElasticsearchJSONFormatter.formatTime", false]], "frontend (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.frontend", false]], "get_conn (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchpythonhook property)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchPythonHook.get_conn", false]], "get_conn() (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlhook method)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLHook.get_conn", false]], "get_es_kwargs_from_config() (in module airflow.providers.elasticsearch.log.es_task_handler)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.get_es_kwargs_from_config", false]], "get_external_log_url() (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler method)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.get_external_log_url", false]], "get_provider_info() (in module airflow.providers.elasticsearch.get_provider_info)": [[0, "airflow.providers.elasticsearch.get_provider_info.get_provider_info", false]], "get_uri() (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlhook method)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLHook.get_uri", false]], "getattr_nested() (in module airflow.providers.elasticsearch.log.es_task_handler)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.getattr_nested", false]], "handler (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.handler", false]], "hit (class in airflow.providers.elasticsearch.log.es_response)": [[5, "airflow.providers.elasticsearch.log.es_response.Hit", false]], "hitmeta (class in airflow.providers.elasticsearch.log.es_response)": [[5, "airflow.providers.elasticsearch.log.es_response.HitMeta", false]], "hits (airflow.providers.elasticsearch.log.es_response.elasticsearchresponse property)": [[5, "airflow.providers.elasticsearch.log.es_response.ElasticSearchResponse.hits", false]], "hook_name (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlhook attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLHook.hook_name", false]], "host (airflow.providers.elasticsearch.hooks.elasticsearch.esconnection attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection.host", false]], "host (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.host", false]], "host_field (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.host_field", false]], "hosts (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchpythonhook attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchPythonHook.hosts", false]], "index_patterns (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.index_patterns", false]], "index_patterns_callable (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.index_patterns_callable", false]], "json_fields (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.json_fields", false]], "json_format (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.json_format", false]], "kwargs (airflow.providers.elasticsearch.hooks.elasticsearch.esconnection attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection.kwargs", false]], "log_line_defaults (in module airflow.providers.elasticsearch.log.es_task_handler)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.LOG_LINE_DEFAULTS", false]], "log_name (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.LOG_NAME", false]], "log_name (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler property)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.log_name", false]], "mark_end_on_close (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.mark_end_on_close", false]], "max_line_per_page (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.MAX_LINE_PER_PAGE", false]], "module": [[0, "module-airflow.providers.elasticsearch.get_provider_info", false], [1, "module-airflow.providers.elasticsearch.hooks.elasticsearch", false], [2, "module-airflow.providers.elasticsearch.hooks", false], [3, "module-airflow.providers.elasticsearch", false], [4, "module-airflow.providers.elasticsearch.log.es_json_formatter", false], [5, "module-airflow.providers.elasticsearch.log.es_response", false], [6, "module-airflow.providers.elasticsearch.log.es_task_handler", false], [7, "module-airflow.providers.elasticsearch.log", false], [8, "module-airflow.providers.elasticsearch.version_compat", false], [9, "module-tests.system.elasticsearch.example_elasticsearch_query", false], [10, "module-tests.system.elasticsearch", false]], "offset_field (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.offset_field", false]], "page (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.PAGE", false]], "password (airflow.providers.elasticsearch.hooks.elasticsearch.esconnection attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection.password", false]], "port (airflow.providers.elasticsearch.hooks.elasticsearch.esconnection attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection.port", false]], "response (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlcursor property)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor.response", false]], "rowcount (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlcursor property)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor.rowcount", false]], "rows (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlcursor property)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor.rows", false]], "schema (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchsqlhook attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLHook.schema", false]], "scheme (airflow.providers.elasticsearch.hooks.elasticsearch.esconnection attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection.scheme", false]], "search() (airflow.providers.elasticsearch.hooks.elasticsearch.elasticsearchpythonhook method)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchPythonHook.search", false]], "set_context() (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler method)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.set_context", false]], "show_tables() (in module tests.system.elasticsearch.example_elasticsearch_query)": [[9, "tests.system.elasticsearch.example_elasticsearch_query.show_tables", false]], "supports_external_link (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler property)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.supports_external_link", false]], "target_index (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.target_index", false]], "task_log_fields (in module airflow.providers.elasticsearch.log.es_task_handler)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.TASK_LOG_FIELDS", false]], "test_run (in module tests.system.elasticsearch.example_elasticsearch_query)": [[9, "tests.system.elasticsearch.example_elasticsearch_query.test_run", false]], "tests.system.elasticsearch": [[10, "module-tests.system.elasticsearch", false]], "tests.system.elasticsearch.example_elasticsearch_query": [[9, "module-tests.system.elasticsearch.example_elasticsearch_query", false]], "to_dict() (airflow.providers.elasticsearch.log.es_response.attributedict method)": [[5, "airflow.providers.elasticsearch.log.es_response.AttributeDict.to_dict", false]], "trigger_should_wrap (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.trigger_should_wrap", false]], "url (airflow.providers.elasticsearch.hooks.elasticsearch.esconnection attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection.url", false]], "use_elasticsearch_hook() (in module tests.system.elasticsearch.example_elasticsearch_query)": [[9, "tests.system.elasticsearch.example_elasticsearch_query.use_elasticsearch_hook", false]], "use_per_run_log_id (in module airflow.providers.elasticsearch.log.es_task_handler)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.USE_PER_RUN_LOG_ID", false]], "user (airflow.providers.elasticsearch.hooks.elasticsearch.esconnection attribute)": [[1, "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection.user", false]], "valid_es_config_keys (in module airflow.providers.elasticsearch.log.es_task_handler)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.VALID_ES_CONFIG_KEYS", false]], "write_stdout (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.write_stdout", false]], "write_to_es (airflow.providers.elasticsearch.log.es_task_handler.elasticsearchtaskhandler attribute)": [[6, "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler.write_to_es", false]]}, "objects": {"airflow.providers": [[3, 0, 0, "-", "elasticsearch"]], "airflow.providers.elasticsearch": [[3, 1, 1, "", "__version__"], [0, 0, 0, "-", "get_provider_info"], [2, 0, 0, "-", "hooks"], [7, 0, 0, "-", "log"], [8, 0, 0, "-", "version_compat"]], "airflow.providers.elasticsearch.get_provider_info": [[0, 2, 1, "", "get_provider_info"]], "airflow.providers.elasticsearch.hooks": [[1, 0, 0, "-", "elasticsearch"]], "airflow.providers.elasticsearch.hooks.elasticsearch": [[1, 3, 1, "", "ESConnection"], [1, 3, 1, "", "ElasticsearchPythonHook"], [1, 3, 1, "", "ElasticsearchSQLCursor"], [1, 3, 1, "", "ElasticsearchSQLHook"], [1, 2, 1, "", "connect"]], "airflow.providers.elasticsearch.hooks.elasticsearch.ESConnection": [[1, 4, 1, "", "close"], [1, 4, 1, "", "commit"], [1, 4, 1, "", "cursor"], [1, 4, 1, "", "execute_sql"], [1, 5, 1, "", "host"], [1, 5, 1, "", "kwargs"], [1, 5, 1, "", "password"], [1, 5, 1, "", "port"], [1, 5, 1, "", "scheme"], [1, 5, 1, "", "url"], [1, 5, 1, "", "user"]], "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchPythonHook": [[1, 5, 1, "", "es_conn_args"], [1, 6, 1, "", "get_conn"], [1, 5, 1, "", "hosts"], [1, 4, 1, "", "search"]], "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLCursor": [[1, 5, 1, "", "body"], [1, 4, 1, "", "close"], [1, 6, 1, "", "cursor"], [1, 6, 1, "", "description"], [1, 5, 1, "", "es"], [1, 4, 1, "", "execute"], [1, 4, 1, "", "fetchall"], [1, 4, 1, "", "fetchmany"], [1, 4, 1, "", "fetchone"], [1, 6, 1, "", "response"], [1, 6, 1, "", "rowcount"], [1, 6, 1, "", "rows"]], "airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLHook": [[1, 5, 1, "", "conn_name_attr"], [1, 5, 1, "", "conn_type"], [1, 5, 1, "", "connector"], [1, 5, 1, "", "default_conn_name"], [1, 4, 1, "", "get_conn"], [1, 4, 1, "", "get_uri"], [1, 5, 1, "", "hook_name"], [1, 5, 1, "", "schema"]], "airflow.providers.elasticsearch.log": [[4, 0, 0, "-", "es_json_formatter"], [5, 0, 0, "-", "es_response"], [6, 0, 0, "-", "es_task_handler"]], "airflow.providers.elasticsearch.log.es_json_formatter": [[4, 3, 1, "", "ElasticsearchJSONFormatter"]], "airflow.providers.elasticsearch.log.es_json_formatter.ElasticsearchJSONFormatter": [[4, 5, 1, "", "default_msec_format"], [4, 5, 1, "", "default_time_format"], [4, 5, 1, "", "default_tz_format"], [4, 4, 1, "", "formatTime"]], "airflow.providers.elasticsearch.log.es_response": [[5, 3, 1, "", "AttributeDict"], [5, 3, 1, "", "AttributeList"], [5, 3, 1, "", "ElasticSearchResponse"], [5, 3, 1, "", "Hit"], [5, 3, 1, "", "HitMeta"]], "airflow.providers.elasticsearch.log.es_response.AttributeDict": [[5, 4, 1, "", "__getattr__"], [5, 4, 1, "", "__getitem__"], [5, 4, 1, "", "to_dict"]], "airflow.providers.elasticsearch.log.es_response.AttributeList": [[5, 4, 1, "", "__bool__"], [5, 4, 1, "", "__getitem__"], [5, 4, 1, "", "__iter__"]], "airflow.providers.elasticsearch.log.es_response.ElasticSearchResponse": [[5, 4, 1, "", "__bool__"], [5, 4, 1, "", "__getitem__"], [5, 4, 1, "", "__iter__"], [5, 6, 1, "", "hits"]], "airflow.providers.elasticsearch.log.es_task_handler": [[6, 3, 1, "", "ElasticsearchTaskHandler"], [6, 1, 1, "", "EsLogMsgType"], [6, 1, 1, "", "LOG_LINE_DEFAULTS"], [6, 1, 1, "", "TASK_LOG_FIELDS"], [6, 1, 1, "", "USE_PER_RUN_LOG_ID"], [6, 1, 1, "", "VALID_ES_CONFIG_KEYS"], [6, 2, 1, "", "get_es_kwargs_from_config"], [6, 2, 1, "", "getattr_nested"]], "airflow.providers.elasticsearch.log.es_task_handler.ElasticsearchTaskHandler": [[6, 5, 1, "", "LOG_NAME"], [6, 5, 1, "", "MAX_LINE_PER_PAGE"], [6, 5, 1, "", "PAGE"], [6, 5, 1, "", "client"], [6, 4, 1, "", "close"], [6, 5, 1, "", "closed"], [6, 5, 1, "", "context_set"], [6, 5, 1, "", "delete_local_copy"], [6, 4, 1, "", "emit"], [6, 5, 1, "", "end_of_log_mark"], [6, 4, 1, "", "format_url"], [6, 5, 1, "", "formatter"], [6, 5, 1, "", "frontend"], [6, 4, 1, "", "get_external_log_url"], [6, 5, 1, "", "handler"], [6, 5, 1, "", "host"], [6, 5, 1, "", "host_field"], [6, 5, 1, "", "index_patterns"], [6, 5, 1, "", "index_patterns_callable"], [6, 5, 1, "", "json_fields"], [6, 5, 1, "", "json_format"], [6, 6, 1, "", "log_name"], [6, 5, 1, "", "mark_end_on_close"], [6, 5, 1, "", "offset_field"], [6, 4, 1, "", "set_context"], [6, 6, 1, "", "supports_external_link"], [6, 5, 1, "", "target_index"], [6, 5, 1, "", "trigger_should_wrap"], [6, 5, 1, "", "write_stdout"], [6, 5, 1, "", "write_to_es"]], "airflow.providers.elasticsearch.version_compat": [[8, 1, 1, "", "AIRFLOW_V_3_0_PLUS"], [8, 1, 1, "", "AIRFLOW_V_3_1_PLUS"]], "tests.system": [[10, 0, 0, "-", "elasticsearch"]], "tests.system.elasticsearch": [[9, 0, 0, "-", "example_elasticsearch_query"]], "tests.system.elasticsearch.example_elasticsearch_query": [[9, 1, 1, "", "CONN_ID"], [9, 1, 1, "", "DAG_ID"], [9, 1, 1, "", "ENV_ID"], [9, 1, 1, "", "execute_query"], [9, 2, 1, "", "show_tables"], [9, 1, 1, "", "test_run"], [9, 2, 1, "", "use_elasticsearch_hook"]]}, "objnames": {"0": ["py", "module", "Python module"], "1": ["py", "data", "Python data"], "2": ["py", "function", "Python function"], "3": ["py", "class", "Python class"], "4": ["py", "method", "Python method"], "5": ["py", "attribute", "Python attribute"], "6": ["py", "property", "Python property"]}, "objtypes": {"0": "py:module", "1": "py:data", "2": "py:function", "3": "py:class", "4": "py:method", "5": "py:attribute", "6": "py:property"}, "terms": {"": [4, 6, 11, 12, 19], "0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 13, 14, 15, 16, 17, 18, 19, 20, 21], "00642a46d0": 12, "0080354502": 12, "01": 12, "01c5150a5f": 12, "02": 12, "027b707d21": 12, "03": 12, "03d": 4, "04": 12, "046f02e5a7": 12, "05": 12, "052e26ad47": 12, "05960ac2eb": 12, "05fe5a4ccf": 12, "06": 12, "060345c0d9": 12, "0653ffe78": 12, "06acf40a43": 12, "07": 12, "08": 12, "08b675cf66": 12, "09": 12, "09a7bd1d58": 12, "09d4718d3a": 12, "0a0e1af800": 12, "0a30706aa7": 12, "0a3ff43d41": 12, "0a68588479": 12, "0b0e4f7a4c": 12, "0b2": 12, "0b23d5601c": 12, "0b680c9492": 12, "0beta1": 12, "0c8e30e43b": 12, "0cb97db893": 12, "0d7fe471d4": 12, "0de31bd73a": 12, "0e5890bdcb": 12, "0f573ee40b": 12, "0f977daa3c": 12, "1": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 13, 14, 15, 16, 17, 18, 19, 20, 21], "10": [11, 12, 13, 18], "1000": 6, "1008ea198a": 12, "10343ec29f": 12, "10411": 12, "10483": 12, "10528": 12, "10533": 12, "10543": 12, "11": [11, 12, 18, 19], "11032": 12, "11238": 12, "11242": 12, "11249": 12, "11447": 12, "11487": 12, "11688": 12, "11826": 12, "11855": 12, "11fbd848a2": 12, "12": [12, 19], "1202": 12, "12082": 12, "12194": 12, "12206": 12, "12212": 12, "12304": 12, "12366": 12, "12390": 12, "123dadda0": 12, "12444": 12, "12449": 12, "12466": 12, "12558": 12, "1275fec92f": 12, "12826": 12, "12917": 12, "12955": 12, "12af6a0800": 12, "12be346adc": 12, "12c3c39d1a": 12, "12c5e5d8a": 12, "13": [11, 12], "13064": 12, "13148": 12, "13310": [11, 12], "13380": 12, "134348e189": 12, "13716ab772": 12, "13717": 12, "13767": 12, "139673d3ce": 12, "13d2f4a7f1": 12, "14": 12, "14013": 12, "14082": [11, 12], "14487": 12, "14625": [11, 12], "14686": [11, 12], "14748": 12, "14763": 12, "14823": [11, 12], "14886": 12, "15": 12, "15163": [11, 12], "15391": 12, "15576": 12, "15667": 11, "15991": 12, "16": [11, 12], "16275": 12, "16294": 12, "16357": [11, 12], "16405": 12, "16436": 12, "16464": 12, "16465": [11, 12], "16467": [11, 12], "16489": [11, 12], "16490": 12, "16501": 12, "16662": 12, "16682": 12, "16adc035b1": 12, "16e7129719": 12, "17": 12, "17551": [11, 12], "17552": [11, 12], "17625": [11, 12], "17682": 12, "17890": 12, "17944": [11, 12], "18": 12, "18121": 12, "18187": 12, "18565": 12, "18613": 12, "19": 12, "19321": 12, "19759": 12, "19882": 12, "19908": 12, "19ebcac239": 12, "1addb55154": 12, "1b059c57d6": 12, "1b18a501f": 12, "1c98f573a2": 12, "1cb456cba1": 12, "1cb9294c64": 12, "1f8b397bee": 12, "1fba5402bb": 12, "1st": 12, "2": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 13, 14, 15, 16, 17, 18, 19, 20, 21], "20": 12, "2020": 12, "2021": [12, 19], "2022": 12, "2023": 12, "2024": 12, "2025": 12, "20344": 12, "2037303eef": 12, "20523": 12, "20614": 12, "20951": 12, "21": 12, "21255": [11, 12], "21257": 12, "21261": [11, 12], "21289": [11, 12], "21398": 12, "21439": 12, "21495": [11, 12], "21553": 12, "21563": 12, "21942": [11, 12], "21990ed894": 12, "22": 12, "22056": 12, "22226": 12, "22382": 11, "22383": 12, "22385": [11, 12], "223a741869": 12, "22521": 12, "2258e13cc7": 12, "225e3041d2": 12, "22811": 12, "22814": [11, 12], "22819": 12, "22884": 12, "23": 12, "23104": 12, "23631": 12, "23821": 12, "23888": [11, 12], "23e743ec09": 12, "23rc1": 12, "24": 12, "24153": [11, 12], "24172": 12, "24229": 12, "24231": 12, "24292": 12, "24307": 12, "24386": 12, "243fe86d4b": 12, "24455": 12, "24533": [11, 12], "24592": [11, 12], "24672": 12, "24702": 12, "247ba31872": 12, "24836": [11, 12], "24895": [11, 12], "249": 1, "24937": 12, "25": 12, "25030": 12, "25618": 12, "25789": [11, 12], "25bdbc8e67": 12, "26": 12, "26289": 12, "26731": 12, "26872": 12, "27": [12, 18], "27196": [11, 12], "27205": 12, "2723508345": 12, "27613": 12, "27758": [11, 12], "27774": 12, "27888": [11, 12], "27937": 12, "28": 12, "28090": 12, "28378d867a": 12, "28651": 12, "28754": 12, "28878": [11, 12], "28929": 12, "28e49e72bf": 12, "29": 12, "292": 12, "29379": 12, "29472": 12, "29482": 12, "295d66f914": 12, "29aab6434f": 12, "2a06e278d2": 12, "2a1": 12, "2a33da0246": 12, "2a34dc9e84": 12, "2a469b3713": 12, "2b1a2f8d56": 12, "2b4da0101f": 12, "2b92c3c74d": 12, "2bb8628463": 12, "2c05187b07": 12, "2ddc100405": 12, "2e20e9f7eb": 12, "2e813eb87d": 12, "2f69b5f007": 12, "2nd": 12, "3": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 13, 14, 15, 16, 17, 18, 19, 20, 21], "30": 12, "30422": 12, "30917": [11, 12], "30963": [11, 12], "30975": 12, "30994": 12, "31": 12, "31252": 12, "31255": [11, 12], "31343": 12, "31379": 12, "31393": 12, "31416": 12, "31427": 12, "31681": 12, "31920": [11, 12], "32001": 12, "32015": 12, "32125": 12, "32243": 12, "32298": 12, "32373": 12, "32381": 12, "32438": [11, 12], "32509": [11, 12], "32536": 12, "32604": 12, "32636": 12, "32646": [11, 12], "32971a1a2d": 12, "32977": [11, 12], "33135": [11, 12], "33281": [11, 12], "33289": [11, 12], "33303": 12, "33455": 12, "33730": 12, "33752": [11, 12], "33754": [11, 12], "33761": [11, 12], "33763": [11, 12], "33933": [11, 12], "34119": [11, 12], "34201": 12, "34251": [11, 12], "34347": 12, "34402": 12, "3442d811cf": 12, "34500f3a2f": 12, "34728": [11, 12], "34788": [11, 12], "34790": [11, 12], "34792": [11, 12], "34793": [11, 12], "34916": 12, "34935": 12, "349b0811c3": 12, "35053": 12, "35187": 12, "35233": 12, "353b1482d3": 12, "35435": 12, "35436": 12, "35537": 12, "35686": 12, "35693": 12, "35707": [11, 12], "35754": [11, 12], "35780": [11, 12], "35836": 12, "3592ff4046": 12, "35b927fe17": 12, "36017": [11, 12], "36112": 12, "36380": 12, "36431": [11, 12], "36464": 12, "36499": 12, "36640": 12, "36675": 12, "36831": [11, 12], "36876": [11, 12], "36945": 12, "3696c34c28": 12, "37015": 12, "37019": 12, "37160": [11, 12], "37326": 12, "37488": 12, "375d1ca229": 12, "37854": [11, 12], "37876": 12, "37880": 12, "38262": 12, "38423": [11, 12], "3878fe6fab": 12, "38863": 12, "38cf214756": 12, "39": [11, 12], "39240": [11, 12], "39328": 12, "39336": [11, 12], "3938f71dfa": 12, "39497": [11, 12], "39552": [11, 12], "39554": 12, "3964": 12, "396b1ba34": 12, "39738": 12, "3bdcd1a7d4": 12, "3c61ca40d7": 12, "3cf15f7b18": 12, "3cf67be387": 12, "3f6d78c09e": 12, "3fd5ef3555": 12, "3rd": 12, "4": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 13, 14, 15, 16, 17, 18, 19, 20, 21], "40448": 12, "40644": 12, "40665": [11, 12], "406f": 19, "40751": [11, 12], "41230": 12, "41396": [11, 12], "41537": [11, 12], "41552": [11, 12], "41559": 12, "41633": [11, 12], "41764": 12, "41871": [11, 12], "41916": [11, 12], "41e611929": 12, "42387": 12, "42505": 12, "42764": [11, 12], "42855": 12, "42862": 12, "43902": [11, 12], "43de625d42": 12, "44011": 12, "44034": [11, 12], "44298": 12, "44629": [11, 12], "44686": [11, 12], "44956": [11, 12], "44973": [11, 12], "44987": [11, 12], "44bd211b19": 12, "45042": 12, "45069": 12, "45263": [11, 12], "45548b9451": 12, "45627": [11, 12], "46146": 12, "46372": 12, "46439": [11, 12], "46608": 12, "46800": 12, "46827": [11, 12], "46891": [11, 12], "46893": 12, "46938": [11, 12], "46962": 12, "46975": 12, "46bbfdade0": 12, "47064": 12, "47203": 12, "47281": 12, "4728fffc5f": 12, "47545": 12, "476d0f6e3d": 12, "47798": 12, "47801": 12, "48223": 12, "48362": 12, "48383": 12, "48457": 12, "48760": 12, "48828": 12, "48849": 12, "48865": [11, 12], "49": 19, "49051": 12, "490b5e816b": 12, "49199": [11, 12], "492ecfe5c0": 12, "49338": 12, "49339": 12, "49450": 12, "49470": [11, 12], "49843": [11, 12], "49877": [11, 12], "49907": 12, "4a44343731": 12, "4a8567b20b": 12, "4b38bed76c": 12, "4c66ebd060": 12, "4d3a": 19, "4d5846f58f": 12, "4d596bcd08": 12, "4dfae23532": 12, "4e8f9cc8d0": 12, "5": [13, 20], "50231": 12, "50454": [11, 12], "50531": 12, "510a6bab45": 12, "512": 19, "51873": [11, 12], "52072": [11, 12], "52139": 12, "5220e4c384": 12, "5246c009c5": 12, "52628": [11, 12], "52644": [11, 12], "52727": 12, "52805": [11, 12], "52967": [11, 12], "52980": [11, 12], "53109": [11, 12], "53243": [11, 12], "53277": [11, 12], "53464": [11, 12], "53629": 12, "53639": [11, 12], "53806": 12, "54": 19, "54258": 12, "54383": 12, "5499": 12, "55101": [11, 12], "55203": 12, "55240": 12, "55455": [11, 12], "55688": 12, "55976af32": 12, "5601": [6, 13], "56056": [11, 12], "56277": 12, "563": 12, "56818": [11, 12], "56ab82ed7a": 12, "57016": [11, 12], "57029": 12, "57456": 12, "57700": 12, "57986": 12, "58138": [11, 12], "58191": 12, "58284": 12, "58316": 12, "58612": [11, 12], "58697": 12, "58727": [11, 12], "589d6dec92": 12, "59249": 12, "59eb5de78c": 12, "5a0be392e6": 12, "5a439e84eb": 12, "5b2d0ad9bd": 12, "5c6e": 19, "5cc14d1fc4": 12, "5cd0bf733b": 12, "5d87bddf0a": 12, "5da831910c": 12, "5e12b3de31": 12, "5fa80b6aea": 12, "6": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 13, 14, 15, 16, 17, 18, 19, 20, 21], "602abe8394": 12, "60d4bcd1d1": 12, "6184facbaa": 12, "61feb6ec45": 12, "62e896bc90": 12, "657384615f": 12, "65dd28eb77": 12, "662cb8c6ac": 12, "6674": 19, "67858fd7e7": 12, "6889a333cf": 12, "68e4c4dcb0": 12, "6933022e94": 12, "6937ae7647": 12, "6adb2dbae4": 12, "6bd450da1e": 12, "6c3a67d4fc": 12, "6cf76d7ac0": 12, "6e51608f28": 12, "6f445e69c3": 12, "6f738d9339": 12, "6ff96af480": 12, "7": [11, 12], "706878ec35": 12, "70dbf40a48": 12, "70f05ac677": 12, "716c4300a6": 12, "717a7588bc": 12, "71c673e427": 12, "724c3a6ead": 12, "7358": 12, "73918925ed": 12, "73b90c48b1": 12, "747f00f2aa": 12, "74892c2195": 12, "75c60923e0": 12, "75fb7acbac": 12, "761c0da723": 12, "7622192441": 12, "7628d47d04": 12, "76ed2a49c6": 12, "7825e8f590": 12, "78b8ea2f22": 12, "79bcc2e668": 12, "79f6383c38": 12, "7a93b19138": 12, "7ab6dc2ecf": 12, "7b2ec33c7a": 12, "7be87d87e2": 12, "7ca9f94846": 12, "7e79997594": 12, "7ebda3898d": 12, "8": [11, 12, 18], "80": 14, "807ad32ce5": 12, "80c327bd3b": 12, "83316b8158": 12, "83741051d5": 12, "840ea3efb9": 12, "853576d901": 12, "857ca4c06c": 12, "85a18e13d9": 12, "8601": 4, "866a601b76": 12, "872b1566a1": 12, "8807": 12, "8886": 12, "8891": 12, "8898": 12, "88bdcfa0df": 12, "8994": 12, "8b146152d6": 12, "8b6b0848a3": 12, "8c42cf1b00": 12, "8ec4": 19, "8ecd576de1": 12, "9": [11, 12, 18], "9026": 12, "905f4752d4": 12, "911b708ffd": 12, "9200": [1, 6, 15], "923bde2b91": 12, "92585ca4cb": 12, "9276310a43": 12, "9320": 12, "935d2831fe": 12, "9370": 12, "9404": 12, "9408": 12, "944a9f5219": 12, "944dc32c2b": 12, "9458": 12, "94f70d8184": 12, "9550": 12, "9604": 12, "97496ba2b4": 12, "97948ecae7": 12, "9845e2282d": 12, "9911": 12, "99534e47f3": 12, "999b70178a": 12, "99bbcd3780": 12, "99df205f42": 12, "99f320354b": 12, "9ab1a6a3e7": 12, "9b39f24780": 12, "9b5d6bfe27": 12, "9c28e766b3": 12, "9c94b72d44": 12, "9d51b42ded": 12, "9d8c77e447": 12, "9fa75aaf7a": 12, "A": [1, 13, 15, 20], "As": 11, "By": 19, "For": [12, 13, 14, 15, 18, 19, 20], "INTO": 20, "If": [5, 11, 19, 20], "In": 11, "It": [5, 11, 19], "No": 12, "The": [1, 5, 6, 11, 12, 13, 14, 18, 19, 21], "There": 19, "These": 20, "To": [6, 19, 20], "With": [11, 12], "_": 11, "__bool__": 5, "__enter__": [11, 12], "__getattr__": 5, "__getitem__": 5, "__iter__": 5, "__version__": [3, 12], "_a": 13, "_all": [1, 13], "_es_read": 11, "_field": 5, "_get_result": 5, "_handler": 6, "_list": 5, "_sourc": 5, "a057b950d7": 12, "a0a05ffedd": 12, "a1a23528da": 12, "a25f8c36ec": 12, "a4a51a02db": 12, "a53d9f6d25": 12, "a59076eae": 12, "a62bd83188": 12, "a79e2d4c4a": 12, "a7eb32a5b2": 12, "a801ea3927": 12, "a87cfe8a77": 12, "a91fd01b0d": 12, "aa61371a07": 12, "aacf2d204a": 12, "abbrevi": 12, "abea189022": 12, "abl": 20, "about": [12, 19, 21], "abov": [11, 12, 13, 19, 20], "abstract": 1, "ac2f72c98d": 12, "ac943c9e18": 12, "accept": 13, "access": [5, 20], "acd51647a4": 12, "across": [11, 12], "actual": 6, "ad": [11, 12, 13, 20], "ad9d8d46b6": 12, "adbb062b50": 12, "add": [11, 12, 20], "addit": [1, 5, 6, 15, 20], "addition": 20, "address": 6, "adhoc": 12, "ae7cb4a1e2": 12, "aeabe994b3": 12, "after": [11, 12, 20], "aip": [11, 12], "airbyt": 12, "airflow": [9, 11, 13, 19, 20, 21], "airflow_2_10_plu": [11, 12], "airflow__elasticsearch__end_of_log_mark": 13, "airflow__elasticsearch__frontend": 13, "airflow__elasticsearch__host": 13, "airflow__elasticsearch__host_field": 13, "airflow__elasticsearch__index_pattern": 13, "airflow__elasticsearch__index_patterns_cal": 13, "airflow__elasticsearch__json_field": 13, "airflow__elasticsearch__json_format": 13, "airflow__elasticsearch__log_id_templ": 13, "airflow__elasticsearch__offset_field": 13, "airflow__elasticsearch__target_index": 13, "airflow__elasticsearch__write_stdout": 13, "airflow__elasticsearch__write_to_": 13, "airflow__elasticsearch_configs__http_compress": 13, "airflow__elasticsearch_configs__verify_cert": 13, "airflow_conn_elasticsearch_default": 14, "airflow_v_2_9_plu": [11, 12], "airflow_v_3_0_plu": 8, "airflow_v_3_1_plu": 8, "airflow_vers": [11, 12], "airflowproviderdeprecationwarn": 12, "airlfow": 12, "aka": 19, "alibaba": 12, "all": [5, 11, 12, 13, 14, 15, 18, 20, 21], "allow": [5, 11, 12, 20], "along": 20, "alreadi": [19, 20], "also": [5, 13, 19, 20], "alwai": 21, "an": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21], "ani": [1, 5, 6, 19, 20], "annot": 12, "apach": [11, 13, 19], "apache_airflow_providers_elasticsearch": 19, "api": [1, 12, 14, 15], "api_kei": 20, "app": 13, "appear": [11, 12], "appli": [11, 12, 20], "apply_default": 11, "apr": 12, "april": 12, "ar": [5, 6, 11, 12, 14, 18, 19, 20, 21], "arg": [1, 11, 12], "argument": [1, 11, 12, 13, 15, 20], "asc": [13, 18, 19], "asctim": 13, "asf": [11, 12], "assert": 12, "assign": [11, 12], "associ": 5, "assum": 6, "atlassian": 12, "attach": 13, "attr": [11, 12], "attr_nam": 5, "attribut": [5, 20], "attributedict": 5, "attributeerror": [11, 12], "attributelist": 5, "aug": 12, "august": 12, "auth": [11, 12], "auto": [11, 12], "autoapi": 12, "autocomplet": 12, "autom": 12, "automat": 11, "avail": [9, 11, 13, 19], "avoid": [11, 12], "awar": 20, "b": 6, "b11525702c": 12, "b15d5578da": 12, "b1e4f37505": 12, "b28c336e8b": 12, "b28c90354f": 12, "b2a28d1590": 12, "b3be18b36f": 12, "b40dffa085": 12, "b5b972a106": 12, "b6bf253062": 12, "b7846750bd": 12, "ba4b": 19, "back": [11, 12], "backcompat": [11, 12], "backend": [11, 12], "backport": 12, "backup_count": 6, "backward": [11, 12], "band": 21, "base": [1, 4, 5, 6], "base_log_fold": 6, "basehook": [1, 11, 12], "bash": 19, "basic_auth": [1, 15], "batch": 12, "bbc627a3da": 12, "bcc7665684": 12, "be75dcd39c": 12, "becaus": 6, "been": 11, "bef82d6ab3": 12, "behaviour": [11, 12], "being": 20, "belong": 19, "below": [18, 19, 20], "bfb054e9e8": 12, "bfb99f5f52": 12, "bin": 19, "binari": 19, "bind": [11, 12], "black": 12, "blob": 11, "block": [11, 12], "bodi": [1, 11, 12], "bool": [6, 8], "both": 20, "bound": [11, 12], "branch": 21, "break": 21, "brees": 12, "breez": 12, "broken": 12, "bst": 19, "bug": 21, "bugfix": [12, 21], "buggfix": 12, "build": [12, 19], "bump": [11, 12], "c": 6, "c063fc688c": 12, "c077d19060": 12, "c23826915d": 12, "c2486b7c09": 12, "c34ef853c8": 12, "c6bc052980": 12, "c6c4f95ed9": 12, "c6ca8a276d": 12, "c6f51c2643": 12, "c761353ce1": 12, "c762e17820": 12, "c7e5bce57f": 12, "c8e348dcb0": 12, "c8fa9e96e2": 12, "c90eec9365": 12, "ca": 20, "ca3e4e75c6": 12, "ca4238eb4d": 12, "ca8249f4a5": 12, "ca9229b6f": 12, "ca_cert": [1, 15, 20], "cach": [1, 11, 12], "call": [6, 11, 12], "callabl": 13, "can": [5, 6, 11, 12, 13, 14, 18, 19, 20, 21], "candid": 12, "capit": 12, "case": 21, "caus": [11, 12], "cb295c351a": 12, "cb4927a018": 12, "cba3c17254": 12, "cbf8001d76": 12, "cde1": 19, "cde15c6e4d3a8ec4ecf4ba4b6674e08ad7de406f": 19, "cdf5d1e1b1": 12, "ce6ae2457": 12, "cead3da4a6": 12, "cert": [1, 15, 20], "certif": 19, "certifi": 19, "cf43b561c0": 12, "cfg": [13, 20], "chan": 6, "chang": [12, 21], "changelog": 12, "chapter": 19, "check": [5, 6, 11, 12, 19], "checksum": [18, 19], "cherri": 21, "choos": [19, 20], "circular": 12, "clarifi": [11, 12], "class": [11, 12, 18], "classifi": [11, 12], "clean": [11, 12], "cleanup": [11, 12], "clearer": 11, "clearli": [11, 12], "client": [1, 5, 6, 11, 12, 15, 20], "close": [1, 6], "cloudwatchtaskhandl": [11, 12], "cluster": 20, "co": [14, 15], "code": [11, 12, 13, 19, 20], "codebas": [11, 12], "collect": [6, 20], "column": 13, "com": [11, 12, 19], "come": 12, "comma": [13, 20], "command": 12, "comment": 12, "commit": [1, 12], "common": [1, 11, 12, 18], "commun": [11, 15], "compat": [1, 11, 12, 18], "compit": 12, "complet": [11, 12], "compliant": [11, 12], "compon": [6, 14], "concaten": 11, "concatin": 12, "condit": [11, 12], "conf": 6, "config": 20, "configur": [6, 11, 12, 15, 20], "conn_id": [1, 9, 14, 16], "conn_name_attr": 1, "conn_typ": 1, "connect": [1, 11, 12, 15], "connector": 1, "consist": [6, 11, 12], "consolid": 12, "construct": [13, 20], "consult": 15, "contain": [13, 19, 20], "context": [6, 11, 12], "context_set": 6, "contextlib": [11, 12], "contribut": 12, "contributor": 12, "conveni": 19, "convert": [4, 11, 12], "copi": 20, "core": 12, "correct": [11, 12, 19], "correctli": 12, "could": 20, "coverag": 12, "creat": [6, 12, 19], "created_at": 20, "creation": 4, "credenti": 1, "critic": 21, "cross": 12, "curl": 19, "current": 15, "cursor": [1, 11, 12], "custom": 20, "d": [5, 19], "d032b30a7c": 12, "d0918d77ee": 12, "d0e7db4024": 12, "d105": 12, "d1aa509bbd": 12, "d1b2a44653": 12, "d1c58d86de": 12, "d200": 12, "d202": 12, "d205": 12, "d213": 12, "d23881c648": 12, "d23a3bbed8": 12, "d2459a241b": 12, "d326149be8": 12, "d400": 12, "d401": 12, "d4473555c0": 12, "d5d119babc": 12, "d760265452": 12, "d7dbfb7e26": 12, "d7de": 19, "d8c4449a91": 12, "d94fa37830": 12, "d9567eb106": 12, "d9ff55cf6d": 12, "dag": [9, 11, 12], "dag_id": [6, 9, 11, 13, 20], "daskexecutor": 12, "data": [5, 11, 12], "databas": 11, "databrick": 12, "date": [4, 11, 12], "datefmt": 4, "db": 11, "db3b57a76": 12, "db3bf8fbfa": 12, "db_test": 12, "dbapi": [1, 14, 16], "dbapihook": [1, 11, 12], "dbf8bb4092": 12, "dc47a11df9": 12, "dcdcf3a2b8": 12, "dd73a0bffa": 12, "dd7ba3cae1": 12, "de": 12, "de9b02f797": 12, "dec": 12, "dec2662190": 12, "decemb": 12, "decid": 21, "decor": [11, 12], "deember": 12, "def": 15, "default": [6, 11, 12, 13, 20, 21], "default_conn_nam": 1, "default_es_kwarg": 6, "default_msec_format": 4, "default_time_format": 4, "default_tz_format": 4, "delai": [6, 12], "delet": [12, 20], "delete_local_copi": 6, "delete_local_log": 20, "delimit": 20, "dep": 19, "depend": [11, 12, 21], "deprec": [11, 12], "describ": 19, "descript": [1, 12], "dest": 19, "detail": [12, 19], "determin": [11, 12], "dev": 12, "devel": 12, "develop": 21, "dict": [1, 11, 12], "dictionari": [5, 14], "did": 11, "diff": 19, "differ": [19, 20], "directli": [5, 6, 20], "directori": 19, "disabl": [11, 12], "discov": 13, "discover": 12, "discoveri": 12, "distribut": [11, 12, 18, 19], "do": [6, 19], "doc": 12, "doc_class": 5, "docstr": [11, 12], "document": [5, 11, 12, 15, 20], "doe": 6, "don": 20, "done": 21, "doubl": 12, "down": 19, "download": [11, 12, 19], "drop": [11, 12, 19], "dsl": 1, "dt": 4, "due": 11, "dup": 12, "duplic": 12, "dynam": 12, "e": [1, 5, 6, 11, 12, 14, 16, 20], "e01323635a": 12, "e027457a24": 12, "e08a": 19, "e13a14c873": 12, "e31e515b28": 12, "e3938899e1": 12, "e4002c3305": 12, "e5ac6c7cfb": 12, "e7194dff6a": 12, "e7e89a07ff": 12, "e8d3de828f": 12, "e9987d5059": 12, "e9eb4813e4": 12, "ea5d5c3ea3": 12, "each": [5, 6], "ead9b00f7c": 12, "easi": 5, "eb884cd380": 12, "ecf4": 19, "echo": 19, "ed3dec85e8": 12, "ee200f8a36": 12, "ee54fe9376": 12, "ee6bd7ee16": 12, "ee7ca128a1": 12, "eef5bc7f16": 12, "ef79a0d1c4": 12, "effici": 6, "either": 13, "elast": [11, 12, 14, 15], "elastic_transport": 1, "elasticearch": [11, 12], "elasticsearch": [11, 15, 16, 19], "elasticsearch_config": 20, "elasticsearch_conn_id": [1, 14, 16], "elasticsearch_dag": 9, "elasticsearch_default": [1, 9, 14], "elasticsearch_id": 20, "elasticsearchhook": 11, "elasticsearchjsonformatt": 4, "elasticsearchlogin": 14, "elasticsearchpassword": 14, "elasticsearchpythonhook": [1, 9, 17], "elasticsearchrespons": 5, "elasticsearchsqlcursor": 1, "elasticsearchsqlhook": [1, 11, 12, 14, 17], "elasticsearchtaskhandl": [5, 6, 11, 12], "elasticserachpythonhook": [11, 12], "element": 5, "els": [11, 12], "emit": [6, 11, 12], "empti": [5, 11, 12], "en": [11, 15], "enabl": [6, 11, 12, 13, 14, 20], "encod": 14, "end": 13, "end_of_log": [11, 12, 13], "end_of_log_mark": 6, "enforc": 12, "ensur": [6, 11], "enter": [1, 15], "entri": 12, "env_id": 9, "environ": [13, 14, 20], "error": [11, 12], "es_conn_arg": [1, 15], "es_connect": [14, 16], "es_hook": [11, 12, 15], "es_host": 15, "es_json_formatt": 7, "es_kwarg": 6, "es_read": [11, 12], "es_respons": 7, "es_task_handl": 7, "esconnect": 1, "eslogmsgtyp": 6, "essenti": 19, "estaskhandl": [11, 12], "etc": 20, "evalu": [5, 12], "event": 6, "ever": 20, "exampl": [1, 9, 11, 12, 13, 14, 18, 19, 20], "example_elasticsearch_queri": [10, 14, 15, 16], "exasol": 12, "except": [6, 11, 12, 21], "exclud": 5, "execut": 1, "execute_queri": 9, "execute_sql": [1, 14, 16], "execution_d": [11, 12, 20], "exist": [6, 18, 20], "experiment": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21], "explain": 11, "explanatori": 12, "export": 14, "extend": [11, 12], "extern": [6, 11, 12], "externalloggingmixin": 6, "extra": [4, 12, 14, 18], "extract": [1, 20], "f": [11, 12, 14, 16], "f326e479d4": 12, "f3521fb0e3": 12, "f3e87c5030": 12, "f5aed58d9f": 12, "f5b96315fe": 12, "f620bcc40a": 12, "f6448b4e48": 12, "f6bd817a3a": 12, "f77417eb0d": 12, "f7f3b675ec": 12, "f8db64c35c": 12, "f9e9d23457": 12, "fab": 12, "fail": [11, 12], "fallback": 6, "fallibl": [11, 12], "fals": [6, 13, 14, 20], "faster": [11, 12], "fbc8f06e1b": 12, "fcbff15bda": 12, "fdd9b6f65b": 12, "fe4605a10": 12, "fe682ec3d3": 12, "feat": [11, 12], "featur": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21], "feb": 12, "februari": 12, "fetch": 20, "fetchal": 1, "fetchmani": 1, "fetchon": 1, "field": [5, 6, 12, 13, 20], "file": [6, 11, 12, 13, 19, 20], "file_task_handl": 6, "filebeat": [6, 11, 12, 20], "filehandl": 6, "filenam": [11, 12, 13, 20], "filename_templ": [11, 12], "filetaskhandl": 6, "final": 12, "find": 20, "fingerprint": 19, "first": [5, 11, 20], "fix": [12, 21], "flexibl": 20, "flit": [11, 12], "fluentd": 20, "flush": 6, "fmt": 4, "folder": [6, 12, 19], "follow": [11, 12, 14, 19, 20, 21], "form": 12, "format": [4, 6, 11, 12, 13, 20], "format_url": 6, "formatt": [6, 13], "formattim": 4, "formmatt": 12, "forward": [11, 12, 20], "found": [6, 11, 12, 20, 21], "foundat": 19, "frame": 14, "framework": 11, "fresh": 12, "from": [1, 5, 6, 9, 11, 12, 13, 15, 18, 20, 21], "from_timestamp": [11, 12], "frontend": [6, 12, 20], "full": [12, 13], "function": [11, 12], "futur": 5, "g": [6, 20], "gcstaskhandl": [11, 12], "gener": [11, 12, 20], "get": [6, 19, 21], "get_conn": [1, 14, 16], "get_df": [11, 12], "get_es_kwargs_from_config": 6, "get_external_log_url": 6, "get_pandas_df": 12, "get_provider_info": [3, 12], "get_uri": 1, "getattr": [11, 12], "getattr_nest": 6, "github": [11, 12], "given": [6, 13], "gmail": 19, "good": [19, 21], "googl": 12, "govern": 21, "gpg": 19, "grammar": 12, "guarante": 11, "guid": [12, 15, 19], "gz": 19, "h": 4, "ha": [6, 11], "handl": [6, 11, 12], "handler": [6, 11, 12, 20], "hash": 12, "have": [6, 11, 20, 21], "hdfstaskhandl": [11, 12], "header": 12, "helper": 5, "here": [6, 20], "high": 12, "highest": 20, "hint": [11, 12], "histori": 12, "hit": [1, 5], "hitmeta": 5, "hook": [3, 11, 12, 14, 15, 16], "hook_nam": 1, "host": [1, 6, 14, 15, 20], "host_field": [6, 11, 12], "host_port": 20, "how": 19, "howev": 20, "html": 15, "http": [1, 6, 11, 12, 13, 14, 15, 19, 20], "http_compress": [14, 20], "i": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21], "id": [1, 6, 19, 20], "identifi": 6, "ignor": [11, 12], "imag": 12, "implement": [6, 11, 12], "import": [11, 12, 19], "improv": [11, 12], "includ": [5, 11, 12, 18, 21], "inclus": 12, "incompat": 11, "increas": 12, "increment": [11, 12], "independ": 21, "index": [1, 5, 6, 11, 12, 13, 20], "index_pattern": [6, 11, 12], "index_patterns_cal": 6, "indic": [6, 19], "individu": [11, 12], "info": 12, "inform": [11, 12, 13, 21], "inherit": [5, 11, 12], "initi": [11, 14], "insert": 20, "insid": [11, 12], "insint": [11, 12], "instal": [11, 12, 21], "install_requir": 11, "instanc": [1, 5, 6, 15], "instanti": [11, 12], "instead": [6, 11, 12, 13, 20], "instruct": [19, 21], "int": [1, 6], "integ": [5, 6], "integr": [11, 12, 14], "intellig": [11, 12], "intend": 6, "interact": [1, 16], "interest": 21, "intern": [6, 11], "interv": [11, 12], "introduc": [11, 12], "invalid": [11, 12], "io": 11, "iso": 4, "issu": [11, 12], "issuer": 19, "item": [5, 6], "iter": [5, 12], "its": 5, "itself": 21, "jan": 12, "januari": 12, "jinja": [11, 12], "json": [4, 11, 12, 13, 14, 20], "json_field": [4, 6, 20], "json_format": [6, 11, 12, 20], "json_formatt": 4, "jsonformatt": 4, "juli": 12, "june": 12, "just": 20, "k": 5, "k8": [11, 12], "ka": 19, "kaxil": 19, "kaxilnaik": 19, "keep": 20, "kei": [5, 6, 11, 12, 14, 19], "kibana": [13, 20], "know": 19, "kubernet": 20, "kueri": 13, "kwarg": [1, 6, 20], "l": 19, "la": 19, "languag": [11, 13], "larg": [11, 12], "later": 20, "latest": [12, 21], "lazili": [5, 12], "least": 11, "left": 19, "legaci": 12, "level": [6, 12, 20], "levelnam": 13, "librari": [11, 12], "licens": 12, "like": [1, 5, 13, 20], "line": [12, 13], "lineno": 13, "link": [6, 11, 12, 19], "list": [1, 5, 9, 11, 12, 13, 15], "liter": [11, 12], "load": 5, "local": [4, 6, 9, 15, 19, 20], "localhost": [1, 6, 13, 15], "locat": 20, "log": [3, 11, 12, 13], "log_id": [6, 11, 12, 13, 20], "log_id_templ": [6, 11, 12], "log_line_default": 6, "log_nam": 6, "log_templ": 20, "logformat": [11, 12], "logger": [6, 12], "logger_nam": 12, "logging_mixin": 6, "loggingmixin": 6, "logical_d": [6, 11, 12], "login": 14, "logo": 12, "logrecord": [4, 20], "logstash": [6, 20], "longer": 20, "lookup": 6, "lower": [11, 12], "m": 4, "made": [11, 19], "mai": [12, 20], "main": [11, 12, 19, 21], "major": [11, 21], "make": [11, 12, 20], "manag": [5, 11, 12, 19], "mandatori": [11, 12], "mani": [1, 15], "manual": 11, "map": [6, 11, 12], "map_index": [11, 12, 13], "mar": 12, "march": 12, "mark": 13, "mark_end_on_clos": 6, "markdown": 12, "match": [1, 12, 19], "match_al": 15, "max_byt": 6, "max_line_per_pag": 6, "mean": 5, "mechan": 12, "messag": [6, 11, 12, 13], "meta": 12, "metadata": [5, 11, 12], "method": [5, 6, 11, 12], "mid": 12, "might": [1, 6, 15, 18, 21], "migrat": [11, 12], "min": [11, 12], "minimum": [11, 12, 18], "minor": 21, "mirror": 19, "miss": [11, 12], "misspel": 12, "mistak": 11, "mistakenli": 11, "mix": 21, "mktemp": 19, "model": [6, 12, 21], "modul": [11, 12, 13, 20], "month": 12, "more": [11, 12, 13], "most": 19, "move": [11, 12], "multipl": [6, 11, 12], "must": 20, "mypi": [11, 12], "na": 6, "naik": 19, "name": [6, 12, 13, 20], "namespac": 12, "nativ": 15, "need": [1, 11, 12, 15, 18, 20], "nest": [11, 12], "new": [11, 12, 21], "next": [12, 21], "nicer": 12, "node": 20, "non": [5, 11, 12], "none": [1, 4, 5, 6, 11, 12, 19], "normal": [12, 13], "note": [6, 12, 13, 14, 20], "notimplementederror": 6, "nov": 12, "novemb": 12, "now": [11, 12, 20], "number": 12, "o": 19, "obj": 6, "object": [1, 5, 6, 13, 20], "objectapirespons": 1, "oct": 12, "octob": 12, "offici": [1, 11, 12, 19], "offset": [6, 13], "offset_field": 6, "old": [12, 20], "older": 21, "onc": [19, 20], "one": [13, 19, 20], "ones": 19, "onli": [12, 21], "oom": [11, 12], "opensearchtaskhandl": [11, 12], "oper": [12, 14], "optimis": 11, "option": [13, 14, 20], "oracl": 12, "order": [6, 11, 12, 18], "org": 19, "origin": 19, "osstaskhandl": [11, 12], "other": 20, "otherwis": [6, 11], "our": 12, "out": [12, 21], "output": [13, 20], "over": [5, 13], "overrid": 12, "overridden": 6, "owner": 19, "packag": 11, "package_nam": 19, "package_vers": 19, "page": [6, 12, 13, 19], "papermil": 12, "param": [1, 6, 12], "paramet": [1, 5, 6, 11, 12, 14, 20], "parent": [11, 12, 20], "parti": 21, "pass": [1, 11, 12, 15, 20], "password": [1, 14], "patchlevel": 21, "path": [1, 12, 13, 15, 20], "pattern": [11, 12, 13], "pem": 20, "pendulum": [11, 12], "pep": [1, 12], "per": [11, 12], "perform": [11, 12], "pgp": 19, "pgpk": 19, "pgpv": 19, "pick": 21, "pip": [12, 18, 19], "placehold": [11, 12], "pleas": [19, 20], "plw0120": 12, "plw2101": 12, "plw2901": 12, "plw3301": 12, "point": 12, "polici": [11, 21], "port": [1, 11, 12, 14, 20], "possibl": [11, 12, 15], "postpon": 12, "pr": 11, "pre": 12, "preced": 13, "precommit": 12, "prefix": 11, "preinstal": 12, "prek": 12, "prepar": [12, 21], "presenc": 5, "present": 5, "presto": 12, "prestohook": [11, 12], "previou": [11, 19, 20], "previous": 11, "primari": [6, 19], "print": [9, 14, 15, 16], "privat": [11, 12], "process": [5, 12, 20], "project": 12, "properli": 20, "properti": [1, 5, 6], "proven": 19, "provid": [11, 13, 19, 20, 21], "provider_download_dir": 19, "provider_test": 12, "prvoider": 12, "pt006": 12, "pt011": 12, "publish": 21, "pull": 12, "py": [11, 14, 15, 16], "py3": 19, "pydocstyl": 12, "pylint": 12, "pypi": [11, 12, 18, 21], "pytestmark": 12, "python": [1, 6, 11, 12, 13, 15, 18, 19, 20], "pyupgrad": 12, "qualifi": [13, 20], "queri": [1, 6, 9, 11, 12, 13, 15], "rais": 6, "rather": [11, 12, 13], "raw": [11, 12], "rc": [11, 12], "rc1": 12, "rc2": 12, "rc3": 12, "re": [5, 11, 12], "read": [6, 11, 12, 20], "readm": [11, 12], "readthedoc": 11, "reappli": 12, "reason": [11, 21], "receiv": 21, "recent": 12, "recommend": [11, 19], "record": [4, 6, 11, 12], "redi": 12, "redistaskhandl": [11, 12], "redund": [11, 12], "ref": 12, "refactor": 12, "refer": [11, 12, 15], "refernc": 12, "regener": 12, "relai": 6, "relas": 12, "relat": [6, 12, 14], "releas": [11, 12, 18], "relev": 19, "rema": 12, "remain": [11, 12], "remot": [11, 12], "remote_log": 20, "remov": [6, 11, 12, 19], "renam": [11, 12], "render": [11, 12], "replac": [11, 12, 20], "repositori": [12, 19], "repres": [5, 6, 13], "reproduc": 12, "requir": [6, 11, 12, 20, 21], "resolv": [11, 12], "resourc": 6, "respect": [11, 12], "respons": [1, 5, 14, 16], "restor": 12, "restrict": [11, 12], "result": [1, 5, 6, 9, 15], "retain": 20, "retriev": 5, "retry_on_timeout": 11, "retry_timeout": 11, "return": [1, 4, 5, 6, 13, 14, 15, 16], "revert": [11, 12], "rewrit": [11, 12], "root": 20, "round": 12, "row": [1, 14, 16, 20], "rowcount": 1, "rsa": 19, "rst": [11, 12], "ruff": [11, 12], "rule": [11, 12, 21], "run": [1, 11, 12, 19, 20], "run_id": [11, 12, 13], "s3taskhandl": [11, 12], "same": [6, 19, 20], "sat": 19, "save": 20, "scenario": 6, "schedul": [11, 12], "schema": [1, 12, 14], "schemaless": [11, 12], "scheme": [1, 13, 14, 20], "scope": 21, "script": [12, 19], "sdist": [18, 19], "sdk": [1, 11, 12], "search": [1, 5, 11, 12, 13, 15], "secret": [11, 12], "section": 20, "secur": 12, "see": [12, 13, 18, 20], "select": 19, "self": [11, 12, 19, 20], "semicolon": [11, 12], "semver": 21, "sensor": 12, "sep": [12, 19], "separ": [12, 13, 21], "septemb": 12, "sequenc": [11, 12], "server": 19, "servic": 6, "set": [6, 13, 20], "set_context": [6, 11, 12], "setup": [6, 12], "sha": 19, "sha512": [18, 19], "shasum": 19, "shim": [11, 12], "ship": 20, "shorter": 12, "should": [6, 11, 14, 19, 21], "show": [11, 12, 14, 16, 20], "show_tabl": 9, "sign": [19, 20], "signatur": [18, 19], "similar": 5, "simplifi": [11, 12], "singl": [1, 15], "singular": 12, "site": 18, "size": [1, 11, 12], "slice": 5, "smart": 12, "so": [6, 11, 12, 20, 21], "softwar": [6, 19, 20], "some": [11, 12, 14, 20], "someapikei": 20, "someth": 13, "sort": [6, 13], "sourc": [0, 1, 3, 4, 5, 6, 8, 9, 12, 14, 15, 16], "specif": [5, 6, 11, 12], "specifi": [6, 14, 18], "speed": 12, "spell": 12, "sphinx": 12, "split": 12, "spuriou": 12, "sql": [1, 11, 12, 18], "sqlalchemi": [11, 12], "sqlclient": [11, 12], "sqlexecutequeryoper": [11, 12], "sqlite": 12, "ssl_verifi": 20, "stabl": 11, "stacklevel": [11, 12], "stakehold": 21, "standard": 20, "start": [6, 11, 12], "state": 12, "statement": 1, "static": 6, "stdout": [13, 20], "step": 19, "still": [19, 20], "store": [5, 6, 13, 20], "str": [1, 6], "stream": 13, "streamhandl": 6, "strftime": 12, "strict": 21, "string": [6, 11, 12, 13, 20], "strip": [11, 12], "structur": [11, 12], "stuff": 12, "style": [4, 12], "subclass": 6, "subject": [11, 12], "successfulli": 20, "sum": 19, "superflu": [11, 12], "support": [6, 11, 12, 18, 20], "supports_external_link": 6, "suppress": [11, 12], "sure": [11, 12, 19], "surround": 12, "suspend": 12, "switch": [11, 12], "synchron": 12, "syntax": 14, "system": [12, 14, 15, 16, 20], "t": 20, "tabl": [9, 14, 16, 20], "tableau": 12, "take": [6, 13], "tar": 19, "target": 12, "target_index": [6, 20], "task": [6, 11, 12, 13, 20], "task_id": [6, 11, 13, 20], "task_inst": 6, "task_log_field": 6, "taskcontextlogg": [11, 12], "taskflow": 12, "taskinst": [6, 11, 12], "taskinstancepydant": [11, 12], "templat": [6, 11, 12, 13, 20], "temporari": 19, "temporarili": [11, 12], "term": [11, 12], "test": [12, 14, 15, 16, 21], "test_run": 9, "tests_common": 12, "text": 12, "than": [11, 12, 13], "thei": 5, "them": [11, 12, 18, 20], "therefor": 11, "thi": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21], "those": 18, "through": [1, 11, 12, 16], "ti": [6, 11, 12, 13, 20], "tidi": 6, "time": [4, 12, 14], "timeout": 14, "timestamp": 6, "timet": [11, 12], "to_dict": 5, "toc": 12, "tool": [11, 12, 20], "toolchain": 12, "top": [18, 19], "track": 20, "transfer": 12, "transform": 5, "tree": 12, "trigger": [11, 12], "trigger_should_wrap": 6, "trinohook": [11, 12], "trove": 11, "true": [5, 6, 9, 13, 14, 15, 16, 20], "trust": 19, "try": [11, 12, 20], "try_numb": [6, 11, 12, 13, 20], "tupl": 1, "turn": 20, "twitter": 12, "type": [1, 6, 11, 12, 13], "typehint": 12, "typo": 12, "ui": [11, 12], "underscor": 11, "undocu": 11, "uniqu": 6, "unit": 12, "unknown": 19, "unmap": 12, "unnecessari": [11, 12], "unpack": [11, 12], "unreach": [11, 12], "unreli": 6, "unsound": [11, 12], "until": 5, "unus": [11, 12], "up": [6, 11, 12], "up038": [11, 12], "updat": [11, 12], "upgrad": [11, 12, 20, 21], "upon": [5, 20], "upper": [11, 12], "uri": [1, 14], "url": [1, 6, 12, 13, 14, 20], "urlpars": [11, 12], "us": [1, 5, 6, 9, 11, 12, 13, 14, 15, 18, 19, 20, 21], "usag": [11, 12], "use_elasticsearch_hook": [9, 15], "use_per_run_log_id": 6, "user": [1, 14, 15, 19, 20], "util": [4, 6], "uv": 12, "v2": 12, "valid": [6, 11, 12, 19], "valid_es_config_kei": 6, "valu": [6, 20], "variabl": [13, 14], "verifi": [12, 18], "verify_cert": 20, "version": [6, 11, 12, 13, 18, 19, 21], "version_compat": [3, 11, 12], "vertica": 12, "via": [18, 19], "view": 20, "vulner": 21, "wa": 11, "wai": [11, 12], "want": [1, 11, 19, 20, 21], "warn": [11, 12, 19], "wasbtaskhandl": [11, 12], "wave": 12, "we": [6, 11, 21], "weaviat": 12, "webserv": [11, 12], "well": [11, 12, 19], "were": 11, "whatev": 6, "wheel": 18, "when": [11, 12, 13, 14, 18, 20, 21], "where": [11, 12, 13, 20, 21], "whether": [6, 14], "which": [5, 6, 13, 21], "while": 11, "whitespac": 12, "whl": 19, "why": 19, "without": [11, 20], "word": 12, "worker": [13, 20], "workspac": 12, "worri": 19, "wrap": 5, "wrapper": 1, "write": [6, 11, 12, 13], "write_stdout": [6, 20], "write_to_": [6, 20], "wrong": 12, "wrongli": 12, "www": 15, "x": [11, 12], "y": [4, 11, 12], "yaml": [11, 12], "yandex": 12, "yank": 12, "you": [1, 11, 14, 15, 18, 19, 20, 21], "your": [11, 20], "yourself": 19, "z": 4, "zone": 4}, "titles": ["airflow.providers.elasticsearch.get_provider_info", "airflow.providers.elasticsearch.hooks.elasticsearch", "airflow.providers.elasticsearch.hooks", "airflow.providers.elasticsearch", "airflow.providers.elasticsearch.log.es_json_formatter", "airflow.providers.elasticsearch.log.es_response", "airflow.providers.elasticsearch.log.es_task_handler", "airflow.providers.elasticsearch.log", "airflow.providers.elasticsearch.version_compat", "tests.system.elasticsearch.example_elasticsearch_query", "tests.system.elasticsearch", "Changelog", "Package apache-airflow-providers-elasticsearch", "Configuration Reference", "ElasticSearch Connection", "ElasticsearchPythonHook", "ElasticsearchSQLHook", "Hook Types", "<code class=\"docutils literal notranslate\"><span class=\"pre\">apache-airflow-providers-elasticsearch</span></code>", "Installing from sources", "Writing logs to Elasticsearch", "Releasing security patches"], "titleterms": {"0": [11, 12], "1": [11, 12], "2": [11, 12], "3": [11, 12], "4": [11, 12], "5": [11, 12], "6": [11, 12], "airflow": [0, 1, 2, 3, 4, 5, 6, 7, 8, 12, 18], "apach": [12, 18], "attribut": [3, 6, 8, 9], "authent": 14, "break": 11, "bug": 11, "chang": [11, 20], "changelog": 11, "class": [1, 4, 5, 6], "configur": [13, 14], "connect": 14, "content": [0, 1, 3, 4, 5, 6, 8, 9], "cross": 18, "default": 14, "depend": 18, "doc": 11, "download": 18, "elasticsearch": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12, 13, 14, 18, 20], "elasticsearch_config": 13, "elasticsearchpythonhook": 15, "elasticsearchsqlhook": 16, "end_of_log_mark": 13, "es_json_formatt": 4, "es_respons": 5, "es_task_handl": 6, "exampl": [15, 16], "example_elasticsearch_queri": 9, "extern": 20, "featur": 11, "fix": 11, "from": 19, "frontend": 13, "function": [0, 1, 6, 9], "get_provider_info": 0, "hook": [1, 2, 17], "host": 13, "host_field": 13, "http_compress": 13, "id": 14, "index_pattern": 13, "index_patterns_cal": 13, "instal": [18, 19], "integr": 19, "json_field": 13, "json_format": 13, "link": 20, "log": [4, 5, 6, 7, 20], "log_id_templ": [13, 20], "misc": 11, "modul": [0, 1, 4, 5, 6, 8, 9], "offici": 18, "offset_field": 13, "onli": 11, "over": 20, "packag": [3, 12, 18, 19], "paramet": 15, "patch": 21, "provid": [0, 1, 2, 3, 4, 5, 6, 7, 8, 12, 18], "pypi": 19, "refer": 13, "releas": [19, 21], "requir": 18, "section": 13, "secur": 21, "sourc": 19, "submodul": [2, 3, 7, 10], "system": [9, 10], "target_index": 13, "test": [9, 10], "tl": 20, "type": 17, "usag": [15, 16], "verifi": 19, "verify_cert": 13, "version_compat": 8, "write": 20, "write_stdout": 13, "write_to_": 13, "yank": 11}}) |