ការស្វែងរក Symfony ដែលមិនបានកើនឡើង: Zero-Downtime Elasticsearch + Async Indexing

នៅលើអ៊ីនធឺណិតអ៊ីនធឺណិតបច្ចុប្បន្ន វាគឺជាអំពី លោក និង ក្នុងនាមជាអ្នកអភិវឌ្ឍន៍ Symfony អ្នកដឹងថាសម្រាប់% ...% គឺជាការបង្វិលបង្វិលបង្វិលបង្វិល។ “search” is not just about finding text performance relevance user experience អត្ថបទនេះបានបង្ហាញពីរបៀបដើម្បីអនុវត្ត a ការរួមបញ្ចូល Elasticsearch នៅក្នុង Symfony 7.4 យើងមិនគឺគ្រាន់តែជា "ការដំឡើង bundle"; យើងកំពុងបង្កើតអន្ដរចនាសម្ព័ន្ធស្រាវជ្រាវដែលមានភាពងាយស្រួលនិងមានពេលវេលាត្រឹមត្រូវដោយប្រើ លោក និង សម្រាប់ . production-grade PHP 8.4 features Attributes Symfony Messenger asynchronous indexing ការរចនាសម្ព័ន្ធ: Performance & Resilience នៅក្នុងការអនុវត្តចម្បង, ការធ្វើឱ្យប្រសើរឡើងប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិបត្តិការប្រព័ន្ធប្រតិ គោលដៅផលិតកម្មរបស់យើង: យើងមិនសរសេរដោយផ្ទាល់ទៅក្នុងឧបករណ៍ដំឡើងផ្ទាល់។ យើងសរសេរទៅក្នុងឧបករណ៍ដំឡើងផ្ទាល់ពេលវេលាហើយប្រើឧបករណ៍ Alias ដើម្បីបង្ហាញកម្មវិធីទៅលើប្រព័ន្ធប្រតិបត្តិការផ្ទាល់ពេលវេលា។ Async Indexing: សៀវភៅទិន្នន័យត្រូវបានបាត់បន្ថយពីសៀវភៅស្វែងរកដោយប្រើ Symfony Messenger ។ ការបោះពុម្ពយ៉ាងតឹងរឹង: យើងប្រើ DTOs និងសេវាកម្មដែលត្រូវបានបោះពុម្ពយ៉ាងតឹងរឹងដោយការជៀកបំពាក់ "កំទូលាយចិញ្ចឹម" នៅពេលដែលអាចធ្វើបាន។ គោលបំណង & ការដំឡើង យើងនឹងប្រើ F (v7.0+) ។ វាគឺជាការផ្តល់នូវការបង្វិលល្អបំផុតនៅលើថ្នាំសម្គាល់ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ Symfony riendsofsymfony/elastica-bundle elasticsearch-php តម្រូវការបរិស្ថាន: លក្ខណៈពិសេស: PHP 8.2+ មូលដ្ឋាន 7.4 ទាញយក Elasticsearch 8.x ការផ្លាស់ប្តូរ dependencies ធ្វើការដូចខាងក្រោមនៅក្នុង terminal របស់អ្នក: composer require friendsofsymfony/elastica-bundle "^7.0" composer require symfony/messenger composer require symfony/serializer ការកំណត់បរិស្ថាន សូមបន្ថែម អ្នករបស់អ្នក ក្នុងកម្មវិធីផលិតកម្ម, សូមធានាថាវាត្រូវបានរក្សាទុកនៅក្នុងអ្នកគ្រប់គ្រងឯកជន (ដូចជា ឬ ) ។ Elasticsearch DSN .env Symfony Secrets HashiCorp Vault # .env ELASTICSEARCH_URL=http://localhost:9200/ ការកំណត់ “Zero-Downtime” នេះគឺជាកន្លែងដែលភាគច្រើននៃការបណ្តុះបណ្តាលមិនជោគជ័យ។ ពួកគេបានកំណត់ឈ្មោះឧបករណ៍អេឡិចត្រូនិច។ យើងនឹងកំណត់គោលបំណងអេឡិចត្រូនិចដើម្បីអនុញ្ញាតឱ្យការបណ្តុះបណ្តាលបណ្តុះបណ្តាលថ្មីដោយគ្មានការកាត់បន្ថយគេហទំព័រ។ ការបង្កើតឬការបច្ចុប្បន្នភាព : config/packages/fos_elastica.yaml # config/packages/fos_elastica.yaml fos_elastica: clients: default: url: '%env(ELASTICSEARCH_URL)%' # Production Tip: Increase timeout for bulk operations config: connect_timeout: 5 timeout: 10 indexes: app_products: # "use_alias: true" is critical for zero-downtime reindexing use_alias: true # Define your distinct settings (analyzers, filters) settings: index: analysis: analyzer: app_analyzer: type: custom tokenizer: standard filter: [lowercase, asciifolding] # Your Persistence strategy (Doctrine integration) persistence: driver: orm model: App\Entity\Product provider: ~ # CRITICAL: We disable the default listener to use Messenger instead listener: insert: false update: false delete: false finder: ~ # Explicit Mapping (Always prefer explicit over dynamic for production) properties: id: { type: integer } name: type: text analyzer: app_analyzer fields: keyword: { type: keyword, ignore_above: 256 } description: { type: text, analyzer: app_analyzer } price: { type: float } stock: { type: integer } created_at: { type: date } ប្រភេទ Domain Layer សូមអរគុណសម្បត្តិផលិតផលដែលមានគុណសម្បត្តិដែលមានគុណសម្បត្តិ PHP 8. namespace App\Entity; use App\Repository\ProductRepository; use Doctrine\DBAL\Types\Types; use Doctrine\ORM\Mapping as ORM; #[ORM\Entity(repositoryClass: ProductRepository::class)] #[ORM\Table(name: 'products')] class Product { #[ORM\Id] #[ORM\GeneratedValue] #[ORM\Column] private ?int $id = null; #[ORM\Column(length: 255)] private ?string $name = null; #[ORM\Column(type: Types::TEXT)] private ?string $description = null; #[ORM\Column] private ?float $price = null; #[ORM\Column] private ?int $stock = 0; #[ORM\Column] private ?\DateTimeImmutable $createdAt = null; public function __construct() { $this->createdAt = new \DateTimeImmutable(); } // ... Getters and Setters public function getId(): ?int { return $this->id; } // ... } ប្រព័ន្ធ ប្រតិបត្តិការ Async Indexing with Messenger (The Senior Pattern) ដូច្នេះប្រសិនបើជាការផ្តល់ ការកាត់បន្ថយតម្រូវការរបស់អតិថិជនរបស់យើងដោយការអនុម័តបន្ទាប់មកយើងនឹងផ្លាស់ប្តូរសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក្តីសេចក fos_elastica ដំណឹង ជាការងាយស្រួល ដើម្បីបញ្ចូលគោលបំណងរបស់អ្នកដែលបានផ្លាស់ប្តូរ។ DTO (Data Transfer Object) namespace App\Message; final readonly class IndexProductMessage { public function __construct( public int $productId, // 'index' or 'delete' public string $action = 'index' ) {} } សកម្មភាព Lifecycle Event យើងកំពុងឆ្លើយតបអំពីសកម្មភាពបច្ចុប្បន្នរបស់យើងដើម្បីផ្ញើសាររបស់យើងដោយស្វ័យប្រវត្តិ។ namespace App\EventListener; use App\Entity\Product; use App\Message\IndexProductMessage; use Doctrine\Bundle\DoctrineBundle\Attribute\AsDoctrineListener; use Doctrine\ORM\Event\PostPersistEventArgs; use Doctrine\ORM\Event\PostRemoveEventArgs; use Doctrine\ORM\Event\PostUpdateEventArgs; use Doctrine\ORM\Events; use Symfony\Component\Messenger\MessageBusInterface; #[AsDoctrineListener(event: Events::postPersist, priority: 500, connection: 'default')] #[AsDoctrineListener(event: Events::postUpdate, priority: 500, connection: 'default')] #[AsDoctrineListener(event: Events::postRemove, priority: 500, connection: 'default')] class ProductIndexerSubscriber { public function __construct( private MessageBusInterface $bus ) {} public function postPersist(PostPersistEventArgs $args): void { $this->dispatch($args->getObject(), 'index'); } public function postUpdate(PostUpdateEventArgs $args): void { $this->dispatch($args->getObject(), 'index'); } public function postRemove(PostRemoveEventArgs $args): void { // When removing, we still need the ID, but the object is technically gone from DB. // Ensure you capture the ID before it's fully detached if needed, // but postRemove usually still has access to the object instance. $this->dispatch($args->getObject(), 'delete'); } private function dispatch(object $entity, string $action): void { if (!$entity instanceof Product) { return; } $this->bus->dispatch(new IndexProductMessage($entity->getId(), $action)); } } ក្រុមហ៊ុន Handler នេះគឺជាកន្លែងដែលការងារពិតប្រាកដបានធ្វើនៅក្នុងបុគ្គលិកខាងលើ។ namespace App\MessageHandler; use App\Entity\Product; use App\Message\IndexProductMessage; use App\Repository\ProductRepository; use FOS\ElasticaBundle\Persister\ObjectPersisterInterface; use Symfony\Component\Messenger\Attribute\AsMessageHandler; #[AsMessageHandler] final class IndexProductHandler { public function __construct( // Inject the specific persister for 'app_products' index // The service ID usually follows the pattern fos_elastica.object_persister. . // Or you can bind it via services.yaml if autowiring fails private ObjectPersisterInterface $productPersister, private ProductRepository $productRepository ) {} public function __invoke(IndexProductMessage $message): void { if ($message->action === 'delete') { // For deletion, we can't fetch the entity as it's gone. // We pass the ID directly to the persister. // Note: In some setups, you might need a stub object or just the ID. // The ObjectPersisterInterface typically expects an object, // but strictly speaking, Elastica needs an ID. // A cleaner way for delete is often using the Elastica Client directly // if the Persister insists on an Entity object. // For simplicity here, we assume the persister handles ID lookups or we use a custom service. // Production-grade approach: Use the Raw Index Service for deletes to avoid hydration issues // But for this example, let's focus on Indexing. return; } $product = $this->productRepository->find($message->productId); if (!$product) { // Product might have been deleted before this worker ran return; } // This pushes the single object to Elasticsearch $this->productPersister->replaceOne($product); } } អ្នកគួរតែចុះឈ្មោះ persister ជាពិសេសនៅក្នុង រថយន្ត ការប្រើប្រាស់ឬការប្រើប្រាស់ ប្រសិនបើអ្នកមានឧបករណ៍ផ្សព្វផ្សាយជាច្រើន services.yaml ObjectPersisterInterface #[Target] # config/services.yaml services: _defaults: bind: # Bind the specific persister to the argument name or type $productPersister: '@fos_elastica.object_persister.app_products' ការស្វែងរក: The Repository Pattern មិនទាញយកប្រព័ន្ធប្រតិបត្តិការ Elastica នៅក្នុងកម្មវិធីគ្រប់គ្រងរបស់អ្នក។ បង្កើតសេវាកម្មឯកទេស។ namespace App\Service\Search; use FOS\ElasticaBundle\Finder\TransformedFinder; class ProductSearchService { public function __construct( // The TransformedFinder returns Doctrine Entities. // If you want raw speed and arrays, use the 'index' service directly. private TransformedFinder $productFinder ) {} /** * @return array */ public function search(string $query, int $limit = 20): array { // Elastica Query Builder $boolQuery = new \Elastica\Query\BoolQuery(); // Match name or description $matchQuery = new \Elastica\Query\MultiMatch(); $matchQuery->setQuery($query); $matchQuery->setFields(['name^3', 'description']); // Boost name by 3x $matchQuery->setFuzziness('AUTO'); // Handle typos $boolQuery->addMust($matchQuery); // Filter by stock (only in stock items) $stockFilter = new \Elastica\Query\Range('stock', ['gt' => 0]); $boolQuery->addFilter($stockFilter); $elasticaQuery = new \Elastica\Query($boolQuery); $elasticaQuery->setSize($limit); // Returns Hydrated Doctrine Objects return $this->productFinder->find($elasticaQuery); } } ការត្រួតពិនិត្យ & ការដំឡើង បានបង្កើត index មុនពេលដែលកម្មវិធីរបស់អ្នកអាចធ្វើការអ្នកគួរតែចាប់ផ្តើមឧបករណ៍នេះ។ php bin/console fos:elastica:create ទិន្នន័យទិន្នន័យទិន្នន័យ (Initial Load) ប្រសិនបើអ្នកមានទិន្នន័យដែលមាននៅក្នុង MySQL, សូមចុចវាទៅ Elastic ។ php bin/console fos:elastica:populate វាត្រូវបានប្រើដោយប្រវត្តិសាស្រ្ត Zero-Downtime: វាត្រូវបានបង្កើតឧបករណ៍បញ្ជាក់ថ្មីនិងបញ្ចប់ឧបករណ៍បញ្ជាក់បន្ទាប់ពីការផ្លាស់ប្តូរឧបករណ៍បញ្ជាក់។ ពិនិត្យឡើងវិញតាម cURL សូមពិនិត្យមើលថាតើការចែកចាយរបស់អ្នកគឺត្រឹមត្រូវដោយផ្ទាល់នៅក្នុង Elastic ។ curl -X GET "http://localhost:9200/app_products/_mapping?pretty" លទ្ធផល ឥឡូវនេះអ្នកមានអគ្គិសនីស្វែងរកដែលមាន: ប្រព័ន្ធ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ប្រតិបត្តិការ ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់ការបញ្ចប់។ Survives Reindexing: អ្នកអាចផ្លាស់ប្តូរ analyzers និង mappings របស់អ្នក, ធ្វើការ fos:elastica:populate ហើយអ្នកប្រើប្រាស់នឹងមិនរកឃើញអ្វីមួយ។ នេះគឺជាគំរូសម្រាប់កម្មវិធី Symfony ដែលមានគុណភាពខ្ពស់។ សូមទាក់ទងមកយើងនៅលើ LinkedIn [ ] សម្រាប់ការយល់ដឹងបន្ថែមទៀតអំពីអគារ PHP & Symfony ។ https://www.linkedin.com/in/matthew-mochalkin/ https://www.linkedin.com/in/matthew-mochalkin/