#hostingforum.kr
php

use MongoDBDriverMonitoringCommandSubscriber;

use MongoDBDriverMonitoringCommandSucceededEvent;

use MongoDBDriverMonitoringCommandStartedEvent;

use MongoDBDriverMonitoringCommandFailedEvent;



class MyCommandSubscriber implements CommandSubscriber

{

    public function commandSucceeded(CommandSucceededEvent $event)

    {

        echo "명령어 수행 성공
";

        echo "명령어 이름: " . $event->getCommandName() . "
";

        echo "명령어 내용: " . json_encode($event->getCommand()) . "
";

        echo "명령어 결과: " . json_encode($event->getReply()) . "
";

        echo "명령어 수행 시간: " . $event->getTimeTaken() . "초
";

    }



    public function commandStarted(CommandStartedEvent $event)

    {

        echo "명령어 수행 시작
";

        echo "명령어 이름: " . $event->getCommandName() . "
";

        echo "명령어 내용: " . json_encode($event->getCommand()) . "
";

    }



    public function commandFailed(CommandFailedEvent $event)

    {

        echo "명령어 수행 실패
";

        echo "명령어 이름: " . $event->getCommandName() . "
";

        echo "명령어 내용: " . json_encode($event->getCommand()) . "
";

        echo "명령어 결과: " . json_encode($event->getReply()) . "
";

    }

}



$mongoClient = new MongoDBClient("mongodb://localhost:27017");

$mySubscriber = new MyCommandSubscriber();



$mongoClient->getServerList()->getServer($mongoClient->getServerList()->getPrimary())->getDatabase("mydb")->getCollection("mycollection")->watch([

    'fullDocument' => true,

    'pipeline' => [

        [

            '$match' => [

                'operationType' => 'insert'

            ]

        ]

    ],

    'fullDocument' => [

        '$changeStream' => [

            'pipeline' => [

                [

                    '$match' => [

                        'operationType' => 'insert'

                    ]

                ]

            ]

        ]

    ]

], $mySubscriber);