code: def get_fs(
      conn_id: str | None, storage_options: dict[str, Any] | None = None
  ) -> AbstractFileSystem:
      from adlfs import AzureBlobFileSystem
  
      if conn_id is None:
          return AzureBlobFileSystem()
  
      conn = BaseHook.get_connection(conn_id)
      extras = conn.extra_dejson
  
      options = {}
      fields = [
          "connection_string",
          "account_name",
          "account_key",
          "sas_token",
          "tenant",
      ]
      for field in fields:
          options[field] = get_field(
              conn_id=conn_id,
              conn_type="azure_data_lake",
              extras=extras,
              field_name=field,
          )
  
      options.update(storage_options or {})
  
      return AzureBlobFileSystem(**options)
  
imports: from __future__ import annotations
  from typing import TYPE_CHECKING, Any
  from airflow.hooks.base import BaseHook
  from airflow.providers.microsoft.azure.utils import get_field
label_desc: Use image node_id 1 for calling a global function with example usage: get_fs(conn_id, storage_options) and returns: AzureBlobFileSystem, AzureBlobFileSystem