በአጠቃላይ የቴክኖሎጂ ገጽታ ውስጥ, ይህ ስለ አግኙን እና እንደ Senior Symfony Developer, እርስዎ እንደ%...% ጥያቄዎች የቴክኒካዊ ጓደኛ ጓደኛ ናቸው. “search” is not just about finding text performance relevance user experience ይህ ጽሑፍ እንዴት መተግበሪያ ይሰራል በ Symfony 7.4 ውስጥ የ Elasticsearch መተግበሪያ መተግበሪያ. እኛ ብቻ "በባድ መጫወት" አይሆንም; እኛ በይነገጽ መጠቀም አንድ ተስማሚ, ከክፍል-የወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ-ወደ አግኙን እና ለ . production-grade PHP 8.4 features Attributes Symfony Messenger asynchronous indexing The Architecture: Performance & Resilience (የአንድ መሐንዲት) አንድ አነስተኛ መተግበሪያ ውስጥ, አንድ የአትክልት update ወደ Elasticsearch አንድ የ HTTP ተስማሚ ይደውሉ. If Elastic is down, your user cannot save their data. That is unacceptable. የእኛን ምርት Strategy: 
 
 
 
 Zero-Downtime Indexing: እኛም በእርግጥ በእርግጥ በ live index ላይ መጻፍ አይችልም. እኛ በ time-stamped index ላይ መጻፍ እንችላለን. Async Indexing: የ Database writes በ Symfony Messenger በመጠቀም ከ Such writes ይቀላቀሉ. Strict Typing: እኛ DTOs እና ጠንካራ የተመሠረተ አገልግሎቶች ይጠቀማሉ, የሚፈልጉት ጊዜ "ማጋ ቅርጸት" ይጠቀማሉ. መስፈርቶች እና መጫን f ይጠቀማል (v7.0+) የተሻለ አጠቃቀም ላይ የተሻለ አጠቃቀም ያቀርባል የኮምፒውተር ኮምፒውተር ኮምፒውተር ኮምፒውተር ኮምፒውተር ኮምፒውተር ኮምፒውተር ኮምፒውተር riendsofsymfony/elastica-bundle elasticsearch-php የአካባቢ መስፈርቶች: 
 
 
 
 የ PHP 8.2+ (የ 8.4 አጠቃቀም) የኮምፒውተር 7.4 የ Elasticsearch 8.x አጠቃቀም መዋቅር መዋቅር የእርስዎን የቴምኒየም ውስጥ የሚከተሉትን መሣሪያዎችን ይጫኑ: composer require friendsofsymfony/elastica-bundle "^7.0"
composer require symfony/messenger
composer require symfony/serializer
 የአካባቢ ጥራት አግኙን የእርስዎ ምርት ውስጥ, ይህ አንድ secret manager ውስጥ የተጠበቀ ነው ያረጋግጡ (እን. ወይም አግኙን Elasticsearch DSN .env Symfony Secrets HashiCorp Vault # .env
ELASTICSEARCH_URL=http://localhost:9200/
 የ “Zero-Downtime” መጫወት አብዛኞቹ ቱዲዮዎች በዚያም ተለዋዋጭ ነው. እነርሱ አንድ ስታቲክ ኢንዱስትሪ ስም ይመሠረዋል. እኛ ጣቢያን መውሰድ አይችልም የፕሮጀክት reindexing ለመውሰድ አንድ alias Strategy ይመሠረዋል. ለመፍጠር ወይም update : 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 (የመደበኛ ሞዴል) ለመውሰድ helyett የእኛን ደንበኞች ጥያቄዎች ለመደገፍ በቀላሉ በኮምፒውተር, እኛ አንድ አስተያየት ወደ መስኮት ይሰጣል. 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 አግኝቷል የእኛን መልዕክት ለመስጠት የ Doctrine እንቅስቃሴዎችን ያውቃሉ. 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));
    }
}
 የንግድ ይህ በባህር ሰራተኞች ውስጥ ውጤታማ ሥራ ነው. 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.<index_name>.<type_name>
        // 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 Logic መውሰድ አይችሉም. አንድ ልዩ አገልግሎት ለመፍጠር. 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<int, \App\Entity\Product>
     */
    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);
    }
}
 ማረጋገጫ እና መተግበሪያ ኢንጂነሪንግ ለመፍጠር የእርስዎ መተግበሪያዎችን ለመፍጠር በፊት, እርስዎ የኮምፒውተር መጀመር አለብዎት. php bin/console fos:elastica:create
 አጠቃላይ መረጃ (Initial Load) በ MySQL ውስጥ የተወሰነ መረጃዎን ከፈለጉ, ወደ Elastic ይጫኑ. php bin/console fos:elastica:populate
 ይህ ኮምፒውተር የ Zero-Downtime Logic ይጠቀማል: ይህ አዲስ ኢንዱስትሪ ለመፍጠር, ይቀላቀሉ እና ከዚያም የአውቶሚካል ይቀላቀሉ. በ curl ላይ ይመልከቱ የእርስዎን ማተሚያ በ Elastic ላይ በቀላሉ ትክክለኛ ነው እንዴት ያረጋግጡ. curl -X GET "http://localhost:9200/app_products/_mapping?pretty"
 መጨረሻዎች አሁን እርስዎ የሚፈልጉትን የሽያጭ መዋቅር አለብዎት: 
 
 
 
 የ DB መጫወት ይጠበቃል: የ Suching hits Elastic, not MySQL. በ Messenger (RabbitMQ / Redis) እና ከዚያ በኋላ በ Messenger (RabbitMQ / Redis) ውስጥ መልዕክቶች ይጀምራል. የ Survives Reindexing: የእርስዎን analyzers እና mappings, fos:elastica:populate መጀመር እና ተጠቃሚዎች አንድ ነገር መውሰድ ይችላሉ. ይህ ከፍተኛ አፈጻጸም Symfony መተግበሪያዎች መደበኛ ነው. ያግኙን ያግኙን LinkedIn ላይ ያግኙን የ PHP & Symfony Architecture ግምገማዎች ያንብቡ. https://www.linkedin.com/in/matthew-mochalkin/ https://www.linkedin.com/in/matthew-mochalkin/

Read My Stories

ይህ ኦዲዮ የተዘጋጀው በታሪኩ የመጀመሪያ ቋንቋ ነው!

የ Symfony Search That Doesn’t Go Down: Zero-Downtime Elasticsearch + Async Indexing (የሲምፎኒያ ማመልከቻው ምንም ውጪ አይደለም) (የሲምፎኒያ ማመልከቻ)

About Author

አስተያየቶች

ተንጠልጣይ መለያዎች

ይህ ጽሑፍ ቀርቧል

Related Stories

SOME ANOMALIES

AMA with Rana Gujral, CEO of Behavioral Signals and Noonies Nominee, on September 30th, 9 am PST

Report Week #28

HackerNoon & The Wild West of Startups

SOME ANOMALIES

AMA with Rana Gujral, CEO of Behavioral Signals and Noonies Nominee, on September 30th, 9 am PST

Report Week #28

HackerNoon & The Wild West of Startups

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps