تبديل نوع MQ لمجموعة Milvus Cluster

يصف هذا الموضوع كيفية تبديل نوع قائمة انتظار الرسائل (MQ) لنشر مجموعة Milvus الحالية. يدعم Milvus تبديل MQ عبر الإنترنت بين Pulsar وKafka وWoodpecker دون توقف.

المتطلبات الأساسية

• مثيل مجموعة Milvus قيد التشغيل مثبت عبر مشغل Milvus أو Helm.
• تمت ترقية مثيل Milvus إلى أحدث إصدار يدعم ميزة تبديل MQ هذه.

التبديل من بولسار/كافكا إلى نقار الخشب (MinIO)

اتبع هذه الخطوات لتبديل نوع MQ من Pulsar أو Kafka إلى Woodpecker مع تخزين MinIO.

الخطوة 1: تحقق من أن مثيل Milvus قيد التشغيل

قبل التبديل، تأكد من تشغيل مثيل مجموعة Milvus بشكل صحيح. يمكنك التحقق من ذلك من خلال إنشاء مجموعة اختبارية وإدراج البيانات وتشغيل استعلام.

الخطوة 2: (اختياري) التحقق من تكوين نقار الخشب

يضبط تكوين Milvus الافتراضي بالفعل نوع تخزين Woodpecker على MinIO، لذلك لا يلزم إجراء تكوين إضافي في معظم الحالات.

ومع ذلك، إذا كنت قد قمت بتخصيص تكوين Woodpecker مسبقًا، يجب التأكد من تعيين woodpecker.storage.type على minio. قم بتحديث تكوين Milvus دون تغيير القيمة mqType:

woodpecker:
  storage:
    type: minio

• بالنسبة لـ Helm، راجع تكوين Milvus مع مخططات Helm للحصول على إرشادات حول تحديث التكوين.
• بالنسبة لمشغل Milvus، راجع تكوين Milvus مع مشغل Milvus للحصول على إرشادات حول تحديث التكوين.

الخطوة 3: تنفيذ مفتاح التبديل MQ

قم بتشغيل الأمر التالي لتشغيل التبديل إلى Woodpecker:

curl -X POST http://<mixcoord_addr>:9091/management/wal/alter \
  -H "Content-Type: application/json" \
  -d '{"target_wal_name": "woodpecker"}'

الخطوة 4: تحقق من اكتمال التبديل

تكتمل عملية التبديل تلقائياً. راقب سجلات ميلفوس للرسائل الرئيسية التالية للتأكد من اكتمال عملية التبديل:

WAL switch success: <MQ1> switch to <MQ2> finish, re-opening required
AlterWAL broadcast message acknowledged by all vchannels
successfully updated mq.type configuration in etcd

التبديل من Woodpecker (MinIO) إلى Pulsar أو Kafka

اتبع هذه الخطوات لتبديل نوع MQ من Woodpecker إلى Pulsar أو Kafka.

الخطوة 1: تحقق من أن مثيل ميلفوس قيد التشغيل

قبل التبديل، تأكد من تشغيل مثيل مجموعة ميلفوس بشكل صحيح.

الخطوة 2: قم بتكوين MQ الهدف

قبل تشغيل التبديل، تحتاج إلى التأكد من توفر خدمة MQ المستهدفة (بولسار أو كافكا) وتكوين الوصول الخاص بها في تكوين Milvus.

الخيار أ: بولسار/كافكا الداخلية (المجمعة مع Helm)

إذا كنت تستخدم خدمة Pulsar أو Kafka المجمعة المجمعة التي تم نشرها بواسطة Helm، فقم بتحديث إصدار Helm لتمكين خدمة MQ المستهدفة وتعطيل Woodpecker. العلامة streaming.enabled=true مطلوبة لتمكين عقدة البث، وهو شرط أساسي لميزة تبديل MQ. على سبيل المثال، للتبديل إلى Pulsar:

helm upgrade -i my-release milvus/milvus \
  --set pulsarv3.enabled=true \
  --set woodpecker.enabled=false \
  --set streaming.enabled=true \
  -f values.yaml

بعد الترقية، تحقق من أن تكوين الوصول إلى MQ الهدف قد تم تحويله إلى تكوين Milvus. على سبيل المثال، بالنسبة لـ Pulsar

pulsar:
  address: <pulsar-proxy-address>
  port: 6650

الخيار ب: بولسار/كافكا الداخلي (تتم إدارته بواسطة مشغل Milvus)

إذا كنت تستخدم مشغل Milvus، فقم بتحديث مورد Milvus المخصص لتضمين تكوين الوصول إلى MQ الهدف. راجع تكوين Milvus مع مشغل Milvus للحصول على تفاصيل حول تحديث تكوين Milvus.

الخيار ج: النابض الخارجي/كافكا الخارجي

إذا كنت تستخدم خدمة بولسار أو كافكا خارجية، فلن تحتاج إلى تغيير mqType. ما عليك سوى إضافة تكوين الوصول إلى MQ الخارجي إلى values.yaml الخاص بك وإعادة تشغيل مثيل Milvus لعرض التكوين.

الخطوة 3: تنفيذ تبديل MQ

قم بتشغيل الأمر التالي لتشغيل التبديل إلى بولسار (استبدل pulsar بـ kafka في حالة التبديل إلى كافكا):

curl -X POST http://<mixcoord_addr>:9091/management/wal/alter \
  -H "Content-Type: application/json" \
  -d '{"target_wal_name": "pulsar"}'

الخطوة 4: تحقق من اكتمال التبديل

تكتمل عملية التبديل تلقائياً. راقب سجلات ميلفوس للرسائل الرئيسية التالية للتأكد من اكتمال عملية التبديل:

WAL switch success: <MQ1> switch to <MQ2> finish, re-opening required
AlterWAL broadcast message acknowledged by all vchannels
successfully updated mq.type configuration in etcd