هذا هو الأمر queue_mover3 الذي يمكن تشغيله في موفر الاستضافة المجاني OnWorks باستخدام إحدى محطات العمل المجانية المتعددة عبر الإنترنت مثل Ubuntu Online أو Fedora Online أو محاكي Windows عبر الإنترنت أو محاكي MAC OS عبر الإنترنت
برنامج:
اسم
queue_mover3 - مستهلك PgQ الذي ينسخ البيانات من قائمة انتظار إلى أخرى.
موجز
queue_mover3 [المفاتيح] config.ini
الوصف
queue_mover هو مستهلك PgQ الذي ينقل الأحداث من قائمة الانتظار المصدر إلى قائمة الانتظار المستهدفة.
إحدى حالات الاستخدام هي عندما يتم إنتاج الأحداث في عدة قواعد بيانات، ثم يتم استخدام queue_mover
دمج هذه الأحداث في قائمة انتظار واحدة يمكن بعد ذلك معالجتها بواسطة المستهلكين الذين
بحاجة للتعامل مع هذه الأحداث. على سبيل المثال، في حالة قواعد البيانات الخاضعة للرقابة، يكون الأمر مناسبًا
لنقل الأحداث من كل قسم إلى قاعدة بيانات قائمة انتظار مركزية واحدة ثم معالجتها
هناك. بهذه الطريقة يكون تكوين قواعد بيانات Partiton وتبعياتها أبسط وأكثر
قوي. حالة استخدام أخرى هي نقل الأحداث من قاعدة بيانات 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. البدء في إنتاج واستهلاك الأحداث
تكوين
مشترك ترتيب المعلمات
اسم العمل
اسم الوظيفة الجزئية التي يقوم بها البرنامج النصي. سيتم تسجيل البرنامج النصي تحت هذا الاسم ل
logdb/logserver. يتم استخدام الاسم أيضًا كافتراضي لاسم المستهلك PgQ. ينبغي أن يكون
فريدة من نوعها.
ملف
موقع ملف pid. إذا لم يتم تقديمه، فلن يُسمح للبرنامج النصي بالتحول إلى شيطان.
ملف تسجيل
موقع ملف السجل.
حلقة_تأخر
إذا كانت العملية مستمرة، فكم من الوقت يجب أن تنام بعد كل حلقة عمل، بالثواني.
الافتراضي: 1.
Connection_lifetime
أغلق وأعد توصيل اتصالات قاعدة البيانات القديمة.
use_skylog
فو.
مشترك PgQ مستهلك المعلمات
queue_name
اسم قائمة الانتظار المراد إرفاقه. لا الافتراضي.
اسم_المستهلك
معرف المستهلك لاستخدامه عند التسجيل. الافتراضي: %(job_name)s
queue_mover المعلمات
src_db
قاعدة بيانات المصدر.
dst_db
قاعدة البيانات المستهدفة.
dst_queue_name
اسم قائمة الانتظار المستهدفة.
مثال التكوين ملف
[queue_mover3]
job_name = eventslog_to_target_mover
src_db = dbname=sourcedb
dst_db = dbname=targetdb
pgq_queue_name = سجل الأحداث
dst_queue_name = Copy_of_eventlog
ملف pid = سجل/%(job_name)s.pid
ملف السجل = pid/%(job_name)s.log
COMMAND خط تحويلات
المفاتيح التالية شائعة في جميع برامج Python المستندة إلى skytools.DBScript.
-h ، - مساعدة
إظهار رسالة المساعدة والخروج
-Q ، - هادئ
جعل البرنامج صامتا
-v ، - الإسراف
جعل البرنامج أكثر مطولا
-د ، - الشيطان
جعل البرنامج يذهب الخلفية
- ميني
إظهار ملف تكوين القالب المعلق.
يتم استخدام المفاتيح التالية للتحكم في العملية الجارية بالفعل. تتم قراءة ملف pidfile من
config ثم يتم إرسال الإشارة إلى معرف العملية المحدد هناك.
-r، --إعادة التحميل
إعادة تحميل التكوين (إرسال SIGHUP)
-س، -توقف
إيقاف البرنامج بأمان (أرسل SIGINT)
-ك ، -قتل
اقتل البرنامج على الفور (أرسل SIGTERM)
استخدم queue_mover3 عبر الإنترنت باستخدام خدمات onworks.net
