Il s'agit de la commande queue_mover3 qui peut être exécutée dans le fournisseur d'hébergement gratuit OnWorks en utilisant l'un de nos multiples postes de travail en ligne gratuits tels que Ubuntu Online, Fedora Online, l'émulateur en ligne Windows ou l'émulateur en ligne MAC OS
PROGRAMME:
Nom
queue_mover3 - Consommateur PgQ qui copie les données d'une file d'attente à une autre.
SYNOPSIS
queue_mover3 [commutateurs] config.ini
DESCRIPTION
queue_mover est un consommateur PgQ qui transporte les événements de la file d'attente source vers la file d'attente cible.
Un cas d'utilisation est lorsque des événements sont produits dans plusieurs bases de données, alors queue_mover est utilisé pour
consolider ces événements dans une file d'attente unique qui peut ensuite être traitée par les consommateurs qui
besoin de gérer ces événements. Par exemple dans le cas de bases de données pattées c'est pratique
pour déplacer les événements de chaque partition vers une base de données de file d'attente centrale, puis les traiter
là. De cette façon, la configuration et les dépendances des bases de données de partitions sont plus simples et plus
robuste. Un autre cas d'utilisation consiste à déplacer des événements de la base de données OLTP vers le serveur de traitement par lots.
Transactionnalité : les événements seront insérés comme une seule transaction du côté cible. Cela signifie
seul batch_id doit être suivi du côté cible.
DÉMARRAGE RAPIDE
La configuration et l'utilisation de base de PgQ peuvent être résumées par les étapes suivantes :
1. PgQ doit être installé à la fois dans les bases de données source et cible. Voir la page de manuel pgqadm pour
détails.
2. La base de données cible doit également avoir le schéma pgq_ext installé. Il est utilisé pour garder la synchronisation
entre deux bases de données.
3. Créez un fichier de configuration queue_mover, par exemple qmover_sourceq_to_targetdb.ini
4. créer des files d'attente source et cible
$ pgqadm.py sourcedb_ticker.ini créer
$ pgqadm.py targetdb_ticker.ini créer
5. lancer le déplaceur de file d'attente en mode démon
$ queue_mover3 -d qmover_sourceq_to_targetdb.ini
6. commencer à produire et à consommer des événements
CONFIG
Commun paramétrage paramètres
nom du travail
Nom du travail particulier effectué par le script. Le script se connectera sous ce nom à
logdb/logserver. Le nom est également utilisé par défaut pour le nom du consommateur PgQ. Ça devrait être
unique.
fichier pid
Emplacement du fichier pid. S'il n'est pas fourni, le script n'est pas autorisé à être démonisé.
fichier journal
Emplacement du fichier journal.
boucle_delay
Si le processus est en cours d'exécution, combien de temps dormir après chaque boucle de travail, en secondes.
Par défaut: 1.
connexion_vietime
Fermez et reconnectez les anciennes connexions de base de données.
use_skylog
fou.
Commun PgQ consommateur paramètres
nom_file_attente
Nom de la file d'attente à laquelle s'attacher. Aucun défaut.
nom_consommateur
Identifiant du consommateur à utiliser lors de l'inscription. Par défaut : %(job_name)s
file_mover paramètres
src_db
Base de données sources.
dst_db
Base de données cible.
nom_file_dst
Nom de la file d'attente cible.
Exemple config filet
[queue_mover3]
nom_travail = eventlog_to_target_mover
src_db = nom de base de données = base de données source
dst_db = nom de base de données = base de données cible
pgq_queue_name = journal des événements
dst_queue_name = copy_of_eventlog
pidfile = log/%(nom_travail)s.pid
fichier journal = pid/%(nom_travail)s.log
COMMAND LINE INTERRUPTEURS
Les commutateurs suivants sont communs à tous les programmes Python basés sur skytools.DBScript.
-h, --aide
afficher le message d'aide et quitter
-q, --calme
rendre le programme silencieux
-v, --verbeux
rendre le programme plus verbeux
-d, --démon
faire passer le programme en arrière-plan
--ini
afficher le fichier de configuration de modèle commenté.
Les commutateurs suivants sont utilisés pour contrôler le processus en cours d'exécution. Le pidfile est lu depuis
config, puis le signal est envoyé à l'ID de processus spécifié ici.
-r, --recharger
recharger la configuration (envoyer SIGHUP)
-s, --stop
arrêter le programme en toute sécurité (envoyer SIGINT)
-k, --kill
tuer le programme immédiatement (envoyer SIGTERM)
Utilisez queue_mover3 en ligne à l'aide des services onworks.net
