当前位置: 首页 > article >正文

pipeline快速将数据存入redis

秒存数据到redis,下边的例子是将数据库的数据,存入redis,然后用缓存数据作为采集任务去目标网站进行采集;

r_db = RedisDB(ip_ports="127.0.0.1:6379", db=0, user_pass"123123")
table_name = "table_name"
pipe = r_db.pipeline()

def send_redis_professional():
    data_list = ['数据队列']
    for rlt in data_list:
        for course in courses:
            for batch in batchs:
                print(rlt)
                pipe.lpush('yzy', str(rlt))
    pipe.execute()


send_redis_professional()

http://www.kler.cn/a/520096.html

相关文章:

  • 【含代码】逆向获取 webpack chunk 下的__webpack_require__ 函数,获悉所有的模块以及模块下的函数
  • wordpress调用指定ID页面的链接
  • Maven下载与配置
  • SYN Flooding的攻击原理
  • 微服务网关鉴权之sa-token
  • 问题修复记录:Linux docker 部署 dify,无法调用宿主机本地服务
  • 计算机网络 (59)无线个人区域网WPAN
  • Stable Diffusion 3.5 介绍
  • 基于STM32单片机设计的宠物喂食监控系统
  • Linux系统编程:进程状态和进程优先级/nice
  • C++——动态管理
  • WinForm保持一个窗口在另一个全屏窗口的上面
  • Redis高阶5-布隆过滤器
  • MFC程序设计(四)窗口创建机制
  • 在php中怎么打开OpenSSL
  • 云服务器快速安装docker, mysql,redis教程
  • 闲来无事复习下基础算法——递归的魅力
  • 【论文阅读】RAG-Reward: Optimizing RAG with Reward Modeling and RLHF
  • Golang并发机制及CSP并发模型
  • mybatis是什么?有什么作用?mybatis的简单使用