代碼示例

本示例的Python版本為3.8，且已安裝Tair-py依賴，Tair-py的快捷安裝命令為：pip3 install tair。

# -*- coding: utf-8 -*-
#!/usr/bin/env python
import time
from tair import Tair
from tair import ResponseError


def get_tair() -> Tair:
    """
    該方法用于連接Tair實(shí)例。
    * host：Tair實(shí)例連接地址。
    * port：Tair實(shí)例的端口號(hào)，默認(rèn)為6379。
    * username：Tair實(shí)例的賬戶，可不填，使用默認(rèn)賬號(hào)登錄。
    * password：Tair實(shí)例的密碼。
    """
    tair: Tair = Tair(
        host = "r-bp************.redis.rds.aliyuncs.com",
        port = 6379,
        db = 0,
        username = "",
        password = "D****123",
    )
    return tair


def add_user_pass(userID: str, device: str, token: str, timeout: int) -> bool:
    """
    該方法為通過(guò)EXHSET命令，將用戶登錄信息存入TairHash數(shù)據(jù)結(jié)構(gòu)中。
    * 將用戶ID（userID）設(shè)置為Key。
    * 將設(shè)備類型（device）設(shè)置為Field。
    * 將用戶Token（token）設(shè)置為Value。
    * 將用戶Token的過(guò)期時(shí)間設(shè)置為Ex。
    """
    try:
        tair = get_tair()
        ret = tair.exhset(userID, device, token, ex=timeout)
        return ret == 1
    except ResponseError as e:
        print(e)
        return False


def print_up(userID):
    """
    該方法打印未過(guò)期的用戶Token信息。
    """
    for i in tair.exhgetall(userID):
        print('{}:{}'.format (userID,i))


if __name__ == "__main__":
    tair = get_tair()
    # 添加user1、user2測(cè)試數(shù)據(jù)。
    user_1 = "user1"
    user_2 = "user2"
    add_user_pass(user_1, "phone", "token_123", 5)
    add_user_pass(user_1, "pad", "token_124", 10)
    add_user_pass(user_2, "pad", "token_456", 10)
    add_user_pass(user_2, "pc", "token_457", 10)
    # 等待6s。
    print("Wait 6 seconds")
    time.sleep(6)
    # 打印此時(shí)未過(guò)期的用戶Token信息。
    print_up(user_1)
    print_up(user_2)
            

Wait 6 seconds
user1:{field: pad, value: token_124}
user2:{field: pad, value: token_456}
user2:{field: pc, value: token_457}