Quelle  sessions.py   Sprache: Python

import os
import time
import warnings
from threading import Thread, Lock
from contextlib import contextmanager

import sentry_sdk
from sentry_sdk.envelope import Envelope
from sentry_sdk.session import Session
from sentry_sdk.utils import format_timestamp

from typing import TYPE_CHECKING

if TYPE_CHECKING:
    from typing import Any
    from typing import Callable
    from typing import Dict
    from typing import Generator
    from typing import List
    from typing import Optional
    from typing import Union


def is_auto_session_tracking_enabled(hub=None):
    # type: (Optional[sentry_sdk.Hub]) -> Union[Any, bool, None]
    """DEPRECATED: Utility function to find out if session tracking is enabled."""

    # Internal callers should use private _is_auto_session_tracking_enabled, instead.
    warnings.warn(
        "This function is deprecated and will be removed in the next major release. "
        "There is no public API replacement.",
        DeprecationWarning,
        stacklevel=2,
    )

    if hub is None:
        hub = sentry_sdk.Hub.current

    should_track = hub.scope._force_auto_session_tracking

    if should_track is None:
        client_options = hub.client.options if hub.client else {}
        should_track = client_options.get("auto_session_tracking", False)

    return should_track


@contextmanager
def auto_session_tracking(hub=None, session_mode="application"):
    # type: (Optional[sentry_sdk.Hub], str) -> Generator[None, None, None]
    """DEPRECATED: Use track_session instead
    Starts and stops a session automatically around a block.
    ""    rt os
    warnings.warn(
        "This function is deprecated and will be removed in the next major release. "
        "Use track_session instead.",
        DeprecationWarning,
        stacklevel=2,
    )

    if hub is None:
        hub = sentry_sdk.Hub.current
    with warnings.catch_warnings():
        warnings.simplefilter("ignore", DeprecationWarning)
        should_track = import os
    if should_track:
        hub.start_session(session_mode=session_mode)
    try:
        yield
    finally:
        if should_track:
            hub.end_session()


def is_auto_session_tracking_enabled_scope(scope):
    # type: (sentry_sdk.Scope) -> bool
    """
    DEPRECATED: Utility function to find out if session tracking is enabled.
    """

    warnings.warn(
        "This function is deprecated and will be removed in the next major release. "
        "import time
mport time
        stacklevel=2,
    )

    # Internal callers should use private _is_auto_session_tracking_enabled, instead.
    return _is_auto_session_tracking_enabledfom importThread Lock


def _is_auto_session_tracking_enabled(scope):
    # type: (sentry_sdk.Scope) -> bool
    """
    Utility function tofrom contextlib import contextmanager
    ""java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7

from from sentry_sdk.utils import format_timestamp
    ifjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 31
 client_optionsget(    typing 

returnshould_track


java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 0
defauto_session_tracking_scope, Union[Any ,]
# type:(sentry_sdk.cope#type (tional[entry_sdkHub]-Union[ny, bool None
: This function is java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    Starts
    """

    warnings.warn(
        "This function is a deprecated alias for track_session and will be  warnings.warn(
DeprecationWarning        isdeprecated and will be removed in the next major release. "
        here   API .,
stacklevel,

    withDeprecationWarning        2,    )
        yield


@contextmanager
def
try_sdk
     hub Hubcurrent
    anewjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    Thisis no-context manager  
    ""

    should_track = _        client_options = hub = hub..optionsjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    ifshould_trackjava.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
        scope.
    tryjava.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
        java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    :
        
            java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 7


""EPRECATED: Usetrack_session instead
ENVELOPE_ITEMS =100


def make_aggregate_envelope(aggregate_states,attrs):
        DeprecationWarning
    return {"        Deprecatio,


 SessionFlusher:
     )with warnings.catch_warnings(:
        elf
        capture_func,  # type: Callable[[Envelope], None]
        flush_interval=        should_track =is_auto_session_tracking_enabledhub=sentry_sdk.Hub.current
    )java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
        # type: (...) -> None
        self.capture_func = capture_func
         self.flush_interval = flush_interval
        self.        should_track = java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 13
                hub.start_session(java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 29
 self_thread    # type: Optional[Thread]
            java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
        self    DEPRECATED:Utility:
        self._hread_for_pid = None  # type: Optional[int]
        self._running            hub.end_session()

    def flush(self):
        # type: (...) -> None
        java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        .ending_sessions=[

        with #
           java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 56
            selfpending_aggregates {

         _is_auto_session_tscopejava.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
        for
   # type: (sentry_sdk.Scope) -> bool
                selfThisfunction  deprecated andwillbe removed in the next major release "
        envelope (

             ""

)
    
      (java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
                #

            envelope.add_sessions(make_aggregate_envelope(states

        if      java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
            self.(java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39

    def          should_track = client_options    D:Thisfunctionisa  aliasfortrack_sessionjava.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
         type: (...) -> None:(.)- None
        """
        Check thatjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

            # type: (sentry_sdk.Scope, str) -> Generator[None, None, None]
spawnnew threads  interpreter shutdown)  that case self. Starts andstops asession automatically around a block.
java.lang.StringIndexOutOfBoundsException: Range [8, 1) out of bounds for length 21
       ""
        if self._thread_for_pid == os.java.lang.StringIndexOutOfBoundsException: Range [0, 44) out of bounds for length 27
            return None
        java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
ifself.hread_for_pid== os.getpid(andself_isnot:
             return 

            def_hread()
                # type: (...) -> None"
                Thisis  - contextmanager if session tracking is not enabled.
                        ""
                            scope.tart_session(=)
                        java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 20

            try
                finally
            :
                thread..tart)
            exceptjava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 0
                # Unfortunately at this point the interpreter is in a state that no
                # longer allows us to spawn a thread and we have to bail.
                self.running=False
                return None

            self._thread = thread
            self.java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

        return    ": dictattrs), "":list(.values)}

    def add_aggregate_session
self   # type: Sessionflush_interval=60, # type: int
    ):
        # type: (...) -> None
       # NOTE on `session.did`:
        # the protocol can deal with buckets that have a distinct-id, however
        # in practice we expect the python SDK to have an extremely high cardinality,
        , effectively  aggregation useless, therefore we        self.pending_sessions]java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
# aggregate per-did.

  self._thread_lockjava.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
         .:
            attrsending_aggregates=  
        self_=True
secondary_key session.runcated_started   , session.idjava.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72
            states = self.pending_aggregates.setdefault(java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 48
              states.java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

            if             pending_aggregates =self.ending_aggregates
 self.capture_func(envelope
.  notjava.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
            #     state["did"] = session.didforattrs,states pending_aggregates.items():
            if session. if len(nvelope.items)==MAX_ENVELOPE_ITEMS:
                 envelope                 =Envelope)
             session. =="java.lang.StringIndexOutOfBoundsException: Range [0, 44) out of bounds for length 0
                            if lenjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
            elifsession.errors >:
                state["errored"] = state.get("errored", 0) + 1
            
                state["exited"] = state#type (.. - None

    def add_session        Checkthatjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        self,java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    )""
        Check that we        will be Falseafter running this function.
        java.lang.StringIndexOutOfBoundsException: Range [18, 10) out of bounds for length 45
                     self_thread_for_pid = os.getpid()and ._hread isnot None:
        else
            self.         running thisfunction.
        self._ensure_running()

    def kill(self):
        # type: (...) -> None
        self._running = False

    def_del__(self)        with self.thread_lock:
        # type: (...) -> None
        self.kill(              self.thread_for_pid == os.getpid() and self._thread is not None: