K8s: 集群内Pod通信机制之DNS

文章目录

• • @[toc]
  • • 数据插入
    • 数据查询
    • 数据更新
    • 数据删除
    • 查询存在的所有key

个人主页：丷从心·

系列专栏：Python数据库

学习指南：Python学习指南

数据插入

from redis import Redis


def insert_data():
    redis_cli = Redis(host='localhost', port=6379, db=0)

    result = redis_cli.set('name', '从心')
    if result:
        print('数据插入成功...')
    else:
        print('数据插入失败...')


if __name__ == '__main__':
    insert_data()

• redis_cli = Redis(host='localhost', port=6379, db=0)用于连接数据库
  • host用于指定数据库IP地址，localhost表示本地
  • port用于指定数据库端口
  • db用于指定数据仓库
• result = redis_cli.set('name', '从心')用于插入一个字符串，插入成功时返回True，插入失败时返回False

数据查询

from redis import Redis


def query_data():
    redis_cli = Redis()

    result = redis_cli.get('name')
    if result:
        print(result.decode('utf-8'))
    else:
        print('数据不存在...')


if __name__ == '__main__':
    query_data()

数据更新

from redis import Redis


def update_data():
    redis_cli = Redis()

    result = redis_cli.set('name', 'follow__my_heart')
    if result:
        print('数据更新成功...')
    else:
        print('数据更新失败...')

    result = redis_cli.get('name')
    if result:
        print(result.decode('utf-8'))
    else:
        print('数据不存在...')


if __name__ == '__main__':
    update_data()

数据删除

from redis import Redis


def delete_data():
    redis_cli = Redis()

    result = redis_cli.delete('name')
    if result:
        print('数据删除成功...')
    else:
        print('数据删除失败...')


if __name__ == '__main__':
    delete_data()

查询存在的所有key

from redis import Redis


def query_keys():
    redis_cli = Redis()

    results = redis_cli.keys()
    if results:
        print(results)
    else:
        print('数据查询失败...')


if __name__ == '__main__':
    query_keys()