queue_splitter3 - ক্লাউডে অনলাইন

কার্যক্রম:

NAME এর

queue_splitter3 - PgQ ভোক্তা যেটি একটি সারির থেকে বিভিন্ন টার্গেটে ইভেন্ট পরিবহন করে
মুদ্রার উলটা পিঠ

সাইনোপিসিস

queue_splitter3 [সুইচ] config.ini

বর্ণনাঃ

queue_spliter হল PgQ ভোক্তা যেটি সোর্স কিউ থেকে বিভিন্ন টার্গেটে ইভেন্ট পরিবহন করে
সারি প্রতিটি ইভেন্টে ev_extra1 ফিল্ড দেখায় কোন টার্গেট সারিতে যেতে হবে।
(pgq.logutriga() সেখানে টেবিলের নাম রাখে।)

একটি ব্যবহারের ক্ষেত্রে OLTP ডাটাবেস থেকে ব্যাচ প্রসেসিং সার্ভারে ইভেন্টগুলি সরানো। ব্যবহার করে
কিউ স্প্লিটারের সাহায্যে ব্যাচ প্রক্রিয়াকরণের জন্য সমস্ত ধরণের ইভেন্ট সরানো সম্ভব
ভোক্তা এইভাবে OLTP ডাটাবেস কম ভিড় রাখে।

দ্রুত শুরু

বেসিক queue_splitter সেটআপ এবং ব্যবহার নিম্নলিখিত ধাপগুলি দ্বারা সংক্ষিপ্ত করা যেতে পারে:

1. pgq অবশ্যই সোর্স এবং টার্গেট ডাটাবেসে ইন্সটল করতে হবে। জন্য pgqadm ম্যান পৃষ্ঠা দেখুন
বিস্তারিত টার্গেট ডাটাবেসে অবশ্যই pgq_ext স্কিমা ইনস্টল থাকতে হবে।

2. একটি queue_splitter কনফিগারেশন ফাইল সম্পাদনা করুন, বলুন
queue_splitter_sourcedb_sourceq_targetdb.ini

3. উৎস এবং লক্ষ্য সারি তৈরি করুন

$pgqadm.py ticker.ini তৈরি করুন

4. ডেমন মোডে কিউ স্প্লিটার চালু করুন

$ queue_splitter3 queue_splitter_sourcedb_sourceq_targetdb.ini -d

5. ইভেন্ট উত্পাদন এবং গ্রাস করা শুরু করুন

কনফিগ

সাধারণ কনফিগারেশন পরামিতি
কাজের নাম
স্ক্রিপ্ট করে কণা কাজের জন্য নাম। স্ক্রিপ্ট এই নামে লগ করা হবে
logdb/logserver. নামটি PgQ ভোক্তার নামের জন্য ডিফল্ট হিসাবেও ব্যবহৃত হয়। এটা করা উচিত
অনন্য।

পিডফাইল
পিড ফাইলের অবস্থান। যদি না দেওয়া হয়, স্ক্রিপ্ট ডিমনাইজ করার অনুমতি দেওয়া হয় না।

লগ ফাইল
লগ ফাইলের জন্য অবস্থান.

লুপ_বিলম্ব
ক্রমাগত প্রক্রিয়া চলমান থাকলে, প্রতিটি কাজের লুপের পর কতক্ষণ ঘুমাতে হবে, সেকেন্ডে।
ডিফল্ট: 1

সংযোগ_জীবনকাল
পুরানো ডাটাবেস সংযোগগুলি বন্ধ করুন এবং পুনরায় সংযোগ করুন।

use_skylog
foo

সাধারণ PgQ ভোক্তা পরামিতি
সারি_নাম
সংযুক্ত করার জন্য সারির নাম। কোন ডিফল্ট.

ভোক্তার_নাম
নিবন্ধন করার সময় গ্রাহকদের আইডি ব্যবহার করতে হবে। ডিফল্ট: %(job_name)s

queue_splitter পরামিতি
src_db
উৎস ডাটাবেস।

dst_db
টার্গেট ডাটাবেস।

উদাহরণ কনফিগ ফাইল
[সারি_বিভাজন৩]
job_name = queue_spliter_sourcedb_sourceq_targetdb

src_db = dbname = sourcedb
dst_db = dbname=targetdb

pgq_queue_name = sourceq

লগফিল = ~/লগ/%(job_name)s.log
pidfile = ~/পিড/%(job_name)s.pid

কমান্ড লাইন সুইচ

নিম্নলিখিত সুইচগুলি সমস্ত skytools.DBScript-ভিত্তিক পাইথন প্রোগ্রামগুলিতে সাধারণ।

-এইচ, --হেল্প
সাহায্য বার্তা দেখান এবং প্রস্থান করুন

-q, - শান্ত
প্রোগ্রাম নীরব করুন

-v, --ভার্বোস
প্রোগ্রামকে আরও ভার্বস করুন

-d, --ডেমন
প্রোগ্রাম গো ব্যাকগ্রাউন্ড করা

--ini
মন্তব্য করা টেমপ্লেট কনফিগার ফাইল দেখান।

ইতিমধ্যে চলমান প্রক্রিয়া নিয়ন্ত্রণ করতে নিম্নলিখিত সুইচগুলি ব্যবহার করা হয়। পিডফাইল থেকে পড়া হয়
config তারপর সেখানে নির্দিষ্ট প্রসেস আইডিতে সিগন্যাল পাঠানো হয়।

-r, -- পুনরায় লোড করুন
কনফিগার পুনরায় লোড করুন (SIGHUP পাঠান)

-এস, --স্টপ
নিরাপদে প্রোগ্রাম বন্ধ করুন (SIGINT পাঠান)

-কে, --হত্যা
অবিলম্বে প্রোগ্রাম হত্যা করুন (SIGTERM পাঠান)

ব্যবহারের ক্ষেত্রে

সেকেন্ডারি ডাটাবেসে তৈরি ইভেন্টগুলিকে কিভাবে প্রক্রিয়া করা যায় বিভিন্ন সারি দিয়ে কিন্তু শুধুমাত্র আছে
প্রাথমিক ডাটাবেসে এক সারি। এটিও দেখায় কিভাবে এর সাথে সারিতে ইভেন্ট সন্নিবেশ করা যায়
নিয়মিত এসকিউএল সহজেই।

স্কিমা সারি তৈরি করুন;
টেবিল সারি তৈরি করুন।event1 (
-- এটি ইভেন্টের অভ্যন্তরীণ কাঠামোর সাথে সঙ্গতিপূর্ণ হওয়া উচিত
-- এখানে আপনি চেক করতে পারেন যে সঠিক ডেটা সারিতে রাখা হয়েছে
আইডি int4,
নামের পাঠ্য,
--প্রয়োজন নেই, তবে থাকা ভালো:
প্রাথমিক কী (আইডি)
);
-- urlencoded বিন্যাসে সারিতে ডেটা রাখুন, প্রকৃত সন্নিবেশ এড়িয়ে যান
সারিতে ঢোকানোর আগে TRIGGER redirect_queue1_trg তৈরি করুন।event1
প্রতিটি সারি কার্যকর করার পদ্ধতির জন্য pgq.logutriga('একক সারি', 'এড়িয়ে যান');
-- ইভেন্ট 2 এর জন্য উপরেরটি পুনরাবৃত্তি করুন

-- এখন তথ্য সন্নিবেশ করা যেতে পারে:
queue.event1 (id, name) VALUES (1, 'user');

যদি queue_splitterটিকে "singlequeue"-এ রাখা হয়, তাহলে এটি ইভেন্টটিকে টার্গেটে সারিতে ছড়িয়ে দেয়
"queue.event1", "queue.event2" ইত্যাদি নাম দেওয়া হয়েছে। এটি প্রাথমিক ডাটাবেসের উপর PgQ লোড কম রাখে
CPU-ভিত্তিক এবং রক্ষণাবেক্ষণ-ভিত্তিক উভয়ই।

01/15/2016 QUEUE_SPLITTER3(1)

onworks.net পরিষেবা ব্যবহার করে অনলাইনে queue_splitter3 ব্যবহার করুন