这是命令 queue_mover3 可以使用我们的多个免费在线工作站之一在 OnWorks 免费托管服务提供商中运行，例如 Ubuntu Online、Fedora Online、Windows 在线模拟器或 MAC OS 在线模拟器
程序：
您的姓名
queue_mover3 - 将数据从一个队列复制到另一个队列的 PgQ 消费者。
概要
queue_mover3 [开关] config.ini
商品描述
queue_mover 是 PgQ 消费者，它将事件从源队列传输到目标队列。
一种用例是当事件在多个数据库中产生时，queue_mover 用于
将这些事件合并到单个队列中，然后由消费者处理
需要处理这些事件。 例如，在分区数据库的情况下，它很方便
将事件从每个分区移动到一个中央队列数据库中，然后处理它们
那里。 这样分区数据库的配置和依赖就更简单了
强壮的。 另一个用例是将事件从 OLTP 数据库移动到批处理服务器。
事务性：事件将作为一个事务插入到目标端。 这意味着
只需要在目标端跟踪batch_id。
快速开始
基本的 PgQ 设置和使用可以通过以下步骤进行总结：
1. PgQ 必须同时安装在源数据库和目标数据库中。 参见 pgqadm 手册页
细节。
2. 目标数据库还必须安装 pgq_ext 架构。 它用于保持同步
两个数据库之间。
3.创建一个queue_mover配置文件，比如qmover_sourceq_to_targetdb.ini
4. 创建源队列和目标队列
$ pgqadm.py sourcedb_ticker.ini 创建
$ pgqadm.py targetdb_ticker.ini 创建
5. 在守护进程模式下启动队列移动器
$queue_mover3 -d qmover_sourceq_to_targetdb.ini
6. 开始生产和消费事件
配置
相当常见 配置 参数
工作名称
脚本执行的具体工作的名称。 脚本将以此名称登录
日志数据库/日志服务器。 该名称也用作 PgQ 使用者名称的默认值。 它应该是
独特。
pid文件
pid 文件的位置。 如果未给出，则不允许脚本守护进程。
日志文件
日志文件的位置。
循环延迟
如果持续运行进程，每个工作循环后休眠多长时间，以秒为单位。
默认值：1
连接生命周期
关闭并重新连接旧的数据库连接。
使用_skylog
富。
相当常见 PGQ 消费者 参数
队列名称
要附加到的队列名称。 没有默认。
消费者名称
注册时使用的消费者 ID。 默认值：%(job_name)s
队列移动器 参数
源数据库
源数据库。
目标数据库
目标数据库。
目标队列名称
目标队列名称。
例如： 配置 文件
[队列移动器3]
作业名称 = eventlog_to_target_mover
src_db = 数据库名=sourcedb
dst_db = 数据库名=目标数据库
pgq_queue_name = 事件日志
dst_queue_name = 事件日志副本
pidfile = log/%(job_name)s.pid
日志文件 = pid/%(job_name)s.log
指挥 LINE 开关类
以下开关对所有基于 skytools.DBScript 的 Python 程序都是通用的。
-h，--帮助
显示帮助信息并退出
-q, --安静
使程序静音
-v，--详细
使程序更冗长
-d，--守护进程
让程序进入后台
--ini
显示注释模板配置文件。
以下开关用于控制已经运行的进程。 pidfile 是从
config 然后将信号发送到在那里指定的进程 ID。
-r，--重新加载
重新加载配置（发送 SIGHUP）
-s, --停止
安全停止程序（发送 SIGINT）
-k，--杀死
立即终止程序（发送 SIGTERM）
使用 onworks.net 服务在线使用 queue_mover3
