redis_service.cpython-312.pyc•2.55 kB
�
G�h� � �� � d dl Z d dlZd dlZ e j ddd d�� ZdZdefd�Zd edefd
�Z d ede
dz fd �Z d ed e
fd
�Z d ededefd�Z
dededz fd�Zdedefd�Zy)� N� localhosti� T)�host�port�db�decode_responsesi �returnc �b � dt j � � �} t j | dd� | S )N�ssn_�historyz[])�uuid�uuid4� redis_client�hset��
session_ids �=/workspaces/MCP-Server/modul5_ders4/services/redis_service.py�create_new_sessionr s, � ���
�
� �~�&�J����j�)�T�2� �� r c �, � t j | � S �N)r �deleter s r �delete_sessionr
s � � � � �z� *�*r c � � t j | � sy t j | d� }|rt j |� S g S )Nr )r �exists�hget�json�loads)r � history_strs r �get_session_historyr s; � � � � �z� *�� �#�#�J� �:�K�&1�4�:�:�k� "�9�r�9r r c �X � t j | dt j |� � y)uI Belirtilen oturumun tüm konuşma geçmişini yeni listeyle değiştirir.r N)r r r �dumps)r r s r �update_session_historyr" s � ����j�)�T�Z�Z��-@�Ar �role�contentc �t � t | � }|�g }|dk( rdnd|d�}|j |� t | |� y )N�user� assistant)r# r$ )r �appendr" )r r# r$ r � new_messages r �add_message_to_historyr* s? � �!�*�-�G�����%)�V�^�6��QX�Y�K� �N�N�;� ��:�w�/r �keyc �, � t j | � S r )r �get)r+ s r � get_cacher. $ s � � � � �C� � r �valuec �< � t j | |t �� y )N)�ex)r �set�CACHE_EXPIRATION_SECONDS)r+ r/ s r � set_cacher4 ' s � ����S�%�$<��=r )�redisr r �Redisr r3 �strr �intr �listr r" r* r. r4 � r r �<module>r; s� �� � � ��u�{�{� �$�1�t�T� � � ��C� �
+�s� +�s� +�:�C� :�D�4�K� :�B�s� B�T� B�0�s� 0�#� 0�� 0�!�3� !�3��:� !�>�3� >�s� >r