数字货币交易系统 Python实践 代少飞 目录 CONTENTS 常见问题 数据库锁问题 任务调度框架 监控 单击此处添加标题 1 常见问题  队列数据丢失  队列挂掉  负数资产  冲钱一次，转两倍资产 用户资产 用户发现自己资产为负数 负数资产 充一次转双倍 队列数据丢失 队列挂掉 RabbitMQ 撮合或者清算队列数据丢失 订单摆上去，能交易 直接将资产的所有操作放redis里面，利用redis的原子性处理事 务 3 任务调度框架  APScheduler APscheduler架构 APScheduler优点 • 支持定时，定期，一次性任务 • 支持任务持久化，存储器支持广泛(Memory，Postgres， MongoDB，Redis，ZooKeeper，SQLAlchemy等) • 调度器支持广泛(Twisted，gevent，Tornado，asyncio等) o，asyncio等) • 可动态调整(添加，修改，删除)任务 • 远程调用支持RPyC(一个用作远程过程调用，同时也可以用作分 布式计算的Python模块)，少量代码，轻松远程调用 APscheduler+twisted 4 监控  交易系统一行代码写错，可能损失好几百万 监控 • 首先每一笔资金变动都得有变动前后的值和原因 • 挂单精度是否正确 • 一个账户，一个币种，不算手续费，初略盘点

进程管理 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 663 16.1.8 调度器接口 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 675 16.1.9 其他系统信息 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 914 17.5 concurrent.futures --- 启动并行任务 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 914 17.5.1 Executor 对象 . . . . . . . . . . . . . . . . . . . . . . . 939 17.7 sched --- 事件调度器 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 939 17.7.1 调度器对象 . . . . . . . . . . . . . . . . . . . . . . . .

进程管理 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 659 16.1.8 调度器接口 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 671 16.1.9 其他系统信息 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 910 17.5 concurrent.futures --- 启动并行任务 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 910 17.5.1 Executor 对象 . . . . . . . . . . . . . . . . . . . . . . . 935 17.7 sched --- 事件调度器 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 935 17.7.1 调度器对象 . . . . . . . . . . . . . . . . . . . . . . . .

进程管理 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 635 16.1.8 调度器接口 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 648 16.1.9 其他系统信息 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 886 17.5 concurrent.futures --- 启动并行任务 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 886 17.5.1 Executor 对象 . . . . . . . . . . . . . . . . . . . . . . . 910 17.7 sched --- 事件调度器 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 911 17.7.1 调度器对象 . . . . . . . . . . . . . . . . . . . . . . . .

进程管理 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 635 16.1.8 调度器接口 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 648 16.1.9 其他系统信息 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 886 17.5 concurrent.futures --- 启动并行任务 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 886 17.5.1 Executor 对象 . . . . . . . . . . . . . . . . . . . . . . . 910 17.7 sched --- 事件调度器 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 911 17.7.1 调度器对象 . . . . . . . . . . . . . . . . . . . . . . . .

Python赋能智慧物流 主讲人： 康昊 – 调度系统开发工程师 Python赋能智慧物流 目 录 目 录 >> 行业背景 >> 系统/模型实现 >> Q&A Python赋能智慧物流 1-行业背景 · AGV/AMR：自动导引运输车/自主移动机器 人 仓储搬运 车间物料运输 室外无人配送 Python赋能智慧物流 1-行业背景 · 移动机器人行业持续增长 From Python赋能智慧物流 1-行业背景 · AMR调度系统 AGV/AMR两大核心技术领域 AGV/AMR本体定位/控制技 术 AGV/AMR集群调度系统 -状态机 -通讯模块 -运动控制 -任务执行 -外设 对接 -任务调度 -路径规划 -交通管制 -AMR控 制 -外设对接 Python赋能智慧物流 1-行业背景 · 传统AMR调度系统 - 部署限制 - 配置繁琐 - 操作离散 操作离散 Python赋能智慧物流 1-行业背景 · AMR调度系统 - 部署更容易 - 简化操作过程 - 稳定快速且智能 Python赋能智慧物流 1-行业背景 · AMR调度系统 Python赋能智慧物流 2-系统/模型实现 ·Why Python？ - 简单省事 - 易于编写、阅读、测试和维 护 - 支持多种编程范式 - 兼容主流平台 - 完备的标准库和框架

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 624 16.1.8 调度器接口 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 635 16.1 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 859 17.5 concurrent.futures --- 启动并行任务 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 860 17.5.1 Executor 对象 . . . . . . . . . . . . . . . . . . . . . . 884 17.7 sched --- 事件调度器 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 885 17.7.1 调度器对象 . . . . . . . . . . . . . . . . . . . . . . .

print(result3) sqlite_cursor2.close() sqlite_conn2.close() # 关闭连接 ★sched模块 周期进行某任务，每隔一定时间就执行某任务 import time import sched def schedule_func(index): print(f'index: {index} do schedule_func # 创建一个调度器 sched1.enter(3, 1, schedule_func, (index,)) # 延迟3 秒，优先级1，回调函数，参数 sched1.run() # 运行调度器，默认是blocking=True，阻塞模式， 等时间到了才运行，运行回调函数后才继续 print(f'index: {index} 运行调度器回调函数之后的输出 ★schedule模块 # pip3 install schedule import schedule import time import threading # 定义任务 def job(var1): print("Hello " + var1) # schedule.every(5).seconds.do(job,var1="World") schedule

启动并行任务 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 813 17.6 subprocess --- 子进程管理 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 819 17.7 sched --- 事件调度器 . 来为语言分析算法提 供提示。在 Unicode 4.0 中用 U+FEFF 表示 ZERO WIDTH NO-BREAK SPACE 已被弃用（改用 U+2060 (WORD JOINER) 负责此任务）。然而 Unicode 软件仍然必须能够处理 U+FEFF 的两个含义：作为 BOM 它被用来确定 已编码字节的存储布局，并在字节序列被解码为字符串后将其去除；作为 ZERO WIDTH NO-BREAK 对象。firstweekday 是一个整数，用于指定一周的第一天。0 是星期一（默认值），6 是星期天。 Calendar 对象提供了一些可用于对日历数据进行格式化的准备的方法。这个类本身不执行任何格式 化操作。这部分任务应由子类来完成。 206 Chapter 8. 数据类型 The Python Library Reference, 发布 3.8.20 Calendar 实例有下列方法： iterweekdays()

进程管理 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 581 16.1.8 调度器接口 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 591 16.1.9 其他系统信息 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 801 17.5 concurrent.futures --- 启动并行任务 . . . . . . . . . . . . . . . . . . . . . . . . . . . . 801 17.5.1 Executor 对象 . . . . . . . . . . . . . . . . . . . . . . . . . 824 17.7 sched --- 事件调度器 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 824 17.7.1 调度器对象 . . . . . . . . . . . . . . . . . . . . . . . .