o i.@sddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z Gdd d ZGd d d Zd e d edBfddZd edBfddZd edBfddZe ZeeadS)N)RLock)Optional)logger)SageMakerConfigc@sbeZdZdZ ddededeefddZdefd d Zddefd d Z d dZ defddZ dS)SessionzRepresents a single stateful session with file-based storage. Each session has a unique directory where it stores key-value data as JSON files. Sessions have an expiration timestamp and are automatically cleaned up when expired. N session_id session_root expiration_tscCs:||_tj|||_||_|jdur|d|_dSdS)a*Initialize a session instance. Args: session_id: Unique identifier for this session (typically UUID) session_root: Root directory where session directories are stored expiration_ts: Unix timestamp when session expires, or None to load from disk N.expiration_ts)r ospathjoin files_pathr get)selfr r r rp/home/ubuntu/.local/lib/python3.10/site-packages/model_hosting_container_standards/sagemaker/sessions/manager.py__init__s   zSession.__init__keycCsBt||d}t||WddS1swYdS)aStore a JSON-serializable value in the session. Args: key: The key to store the value under value: Must be JSON-serializable (str, int, float, bool, list, dict, None) Raises: TypeError: If value is not JSON-serializable wN)open_pathjsondump)rrvaluefrrrput*s "z Session.putcCsR||}tj|s |St|d }t|WdS1s"wYdS)zRetrieve a value from the session. Args: key: The key to retrieve d: Default value if key doesn't exist Returns: The stored value or default if key not found rN)rr risfilerrload)rrdrrrrrr7s  $z Session.getcCs@tj|jstd|jtd|jt |jdS)zDelete the session and all its stored data from disk. Returns: bool: True if deletion successful Raises: ValueError: If session directory doesn't exist z"session directory does not exist: zclosing session: T) r rexistsr ValueErrorr rinfoshutilrmtree)rrrrremoveHs   zSession.removecCsd|vr td|dtj|rtd|d|dd}tj|j|}tj|}|tj|jtj sCtd|d|S)a-Generate a safe file path within the session directory. Args: key: The key name for the session data file Returns: Absolute path to the file within the session directory Raises: ValueError: If key contains path traversal attempts z..z&Invalid key: '..' not allowed in key ''z)Invalid key: absolute paths not allowed '/-z&Invalid key: path traversal detected ') r$r risabsreplacerrabspath startswithsep)rr sanitized_key file_path resolved_pathrrrrWs    z Session._path)N) __name__ __module__ __qualname____doc__strrfloatrrrr(rrrrrrs  rc@sReZdZdZdefddZdefddZdede efd d Z d d Z d dZ dS)SessionManagera2Manages the lifecycle of stateful sessions with automatic expiration and cleanup. SessionManager maintains a registry of active sessions, each stored in its own directory on disk. It handles session creation, retrieval, expiration checking, and cleanup. Thread-safe for concurrent access. propertiesc Cst|dtd|_|d}|durBtjtd}tj do,t dtj tj B}|r1dn|}t d|r:d nd d |||_i|_t|_z9tj|jd d t |jtj tj Bshtd|jt d|jt|jD] }t||j|j|<qwWdSttfy}z/t d|jd |dtjtd|_tj|jd d t d|jWYd}~dSd}~ww)aQInitialize the SessionManager with configuration properties. Args: properties: Configuration dict with optional keys: - sessions_expiration: Session lifetime in seconds (default: 1200) - sessions_path: Root directory for session storage (default: /dev/shm/sagemaker_sessions) sessions_expirationi sessions_pathNsagemaker_sessionsz/dev/shmz/dev/shm/sagemaker_sessionsz$Sessions path not configured, using z shared memoryztemp directoryz: T)exist_okzCannot write to z Session storage initialized at: z!Failed to initialize sessions at z . Falling back to temp directoryz)Session storage initialized at fallback: )intrr8 expirationr rrtempfile gettempdirr#accessR_OKW_OKrr%r=sessionsr_lockmakedirsPermissionErrorlistdirrOSErrorwarning)rr;r=temp_sessions_pathshm_accessibler errrr}sL    zSessionManager.__init__returncCs|j3|tt}t|j}t||j|}||j |<t |j | d||WdS1s9wYdS)a>Create a new session with a unique ID and expiration timestamp. Also triggers cleanup of any expired sessions before creating the new one. Returns: Session: The newly created session instance with UUID and expiration Thread-safe: Uses internal lock for concurrent access r N)rH_clean_expired_sessionr8uuiduuid4timerArr=rGr rIrr)rr r sessionrrrcreate_sessions     $zSessionManager.create_sessionr cCs|jL|dks |s WddS||jvrtd||j|}|jdurFt|jkrFtd||| WddS|WdS1sRwYdS)aRetrieve a session by ID, checking for expiration. Args: session_id: The unique session identifier Returns: Session instance if found and not expired, None if session doesn't exist or has expired, or if session_id is "NEW_SESSION" or empty Raises: ValueError: If session_id is not found in registry Thread-safe: Uses internal lock for concurrent access NEW_SESSIONNsession not found: zSession expired: )rHrGr$r rUrr% close_sessionrr rVrrr get_sessions     $zSessionManager.get_sessioncCsp|j+|s td|||jvrtd||j|}||j|=WddS1s1wYdS)a&Close and remove a session, deleting all its data. Args: session_id: The unique session identifier to close Raises: ValueError: If session_id is empty/None or not found in registry Thread-safe: Uses internal lock for concurrent access zinvalid session_id: rYN)rHr$rGr(r[rrrrZs    "zSessionManager.close_sessioncCsf|j&t|jD]\}}|jdust|jkr ||q WddS1s,wYdS)aInternal method to remove all expired sessions. Iterates through all sessions and closes any that have expired. Called automatically during session creation to prevent stale session buildup. Thread-safe: Uses internal lock for concurrent access N)rHlistrGitemsr rUrZr[rrrrR s "z%SessionManager._clean_expired_sessionN) r4r5r6r7dictrrrWr8rr\rZrRrrrrr:us9" r:configrQcCs$|jrt|j|jd}t|SdS)zInitialize a SessionManager if stateful sessions are enabled. Args: config: SagemakerConfig instance with session settings Returns: SessionManager instance if enabled, None otherwise )r<r=N)enable_stateful_sessionsr8r<r=r:)r` config_dictrrr_init_session_managers  rccCstS)zGet the global session manager instance. Returns: The global SessionManager instance, or None if not initialized )session_managerrrrrget_session_manager,srecCst}t|atS)aInitialize the global session manager from environment variables. This can be called to reinitialize the session manager after environment variables have been set. Returns: The initialized SessionManager instance, or None if disabled )rfrom_envrcrd)r`rrrinit_session_manager_from_env5s rg)rr r&rBrUrS threadingrtypingrlogging_configrr`rrr:rcrergrf_configrdrrrrs$    d%