starred/monolog

Fork 0

mirror of https://github.com/Seldaek/monolog.git synced 2026-04-26 08:05:53 +03:00

[GH-ISSUE #276] Stream Handler #89

New issue

Closed

opened 2026-03-04 02:12:05 +03:00 by kerem · 8 comments

kerem commented

2026-03-04 02:12:05 +03:00

Owner

Originally created by @harikt on GitHub (Nov 22, 2013).
Original GitHub issue: https://github.com/Seldaek/monolog/issues/276

Hi @Seldaek ,

I was running StreamHandler inside a Gearman Job server and it seems it could not log all the errors.

Probably need to look another handler or is this a bug ?

Originally created by @harikt on GitHub (Nov 22, 2013). Original GitHub issue: https://github.com/Seldaek/monolog/issues/276 Hi @Seldaek , I was running `StreamHandler` inside a Gearman Job server and it seems it could not log all the errors. Probably need to look another handler or is this a bug ?

kerem closed this issue

2026-03-04 02:12:05 +03:00

kerem commented

2026-03-04 02:12:06 +03:00

Author

Owner

@Seldaek commented on GitHub (Nov 22, 2013):

I don't see why it couldn't.. Without more details I can't really help you.

@Seldaek commented on GitHub (Nov 22, 2013): I don't see why it couldn't.. Without more details I can't really help you.

kerem commented

2026-03-04 02:12:06 +03:00

Author

Owner

@harikt commented on GitHub (Nov 22, 2013):

Hey @Seldaek ,

Thanks for the quick reply .

$logger = new Monolog\Logger('fetch');
$stream = new StreamHandler(__DIR__ . '/logs/somelog.log', Logger::DEBUG);
$logger->pushHandler($stream);
$logger->addInfo("I am doing something");

and I have around 5 to 10 gearman clients running.

@harikt commented on GitHub (Nov 22, 2013): Hey @Seldaek , Thanks for the quick reply . ``` php $logger = new Monolog\Logger('fetch'); $stream = new StreamHandler(__DIR__ . '/logs/somelog.log', Logger::DEBUG); $logger->pushHandler($stream); $logger->addInfo("I am doing something"); ``` and I have around 5 to 10 gearman clients running.

kerem commented

2026-03-04 02:12:06 +03:00

Author

Owner

@harikt commented on GitHub (Nov 22, 2013):

probably http://us3.php.net/file_put_contents will be better I guess. Anything else I could share ?

@harikt commented on GitHub (Nov 22, 2013): probably http://us3.php.net/file_put_contents will be better I guess. Anything else I could share ?

kerem commented

2026-03-04 02:12:06 +03:00

Author

Owner

@Seldaek commented on GitHub (Nov 22, 2013):

It should be no problem since the StreamHandler opens all logs with fopen(..., 'a') it will always append to the end.

You can try with:

<?php
$a = fopen('a.log', 'a');
$b = fopen('a.log', 'a');

fwrite($a, 'first'.PHP_EOL);
fwrite($b, 'second'.PHP_EOL);
fwrite($a, 'third'.PHP_EOL);

You end up with a.log that has the three lines we wrote, even with two handles open on the same file.

@Seldaek commented on GitHub (Nov 22, 2013): It should be no problem since the StreamHandler opens all logs with `fopen(..., 'a')` it will always append to the end. You can try with: ``` php <?php $a = fopen('a.log', 'a'); $b = fopen('a.log', 'a'); fwrite($a, 'first'.PHP_EOL); fwrite($b, 'second'.PHP_EOL); fwrite($a, 'third'.PHP_EOL); ``` You end up with a.log that has the three lines we wrote, even with two handles open on the same file.

kerem commented

2026-03-04 02:12:06 +03:00

Author

Owner

@harikt commented on GitHub (Nov 22, 2013):

I am trying in gearman worker. Do you see an overlapping of the items ?

@harikt commented on GitHub (Nov 22, 2013): I am trying in gearman worker. Do you see an overlapping of the items ?

kerem commented

2026-03-04 02:12:06 +03:00

Author

Owner

@Seldaek commented on GitHub (Nov 22, 2013):

I don't have a gearman setup but no I don't see any overlap, well multiple requests can be interlaced but every line is a clean write from one request.

@Seldaek commented on GitHub (Nov 22, 2013): I don't have a gearman setup but no I don't see any overlap, well multiple requests can be interlaced but every line is a clean write from one request.

kerem commented

2026-03-04 02:12:06 +03:00

Author

Owner

@harikt commented on GitHub (Nov 22, 2013):

:( bad time .

@harikt commented on GitHub (Nov 22, 2013): :( bad time .

kerem commented

2026-03-04 02:12:06 +03:00

Author

Owner

@harikt commented on GitHub (Dec 2, 2013):

Tested with client and worker . Seems something else is wrong. So closing the issue.

client.php

<?php
$client = new GearmanClient();
$client->addServer("127.0.0.1", "4730");
$client->setCompleteCallback(function ($task) {                    
    $data = $task->data();
    echo "task completed " . PHP_EOL;
});
for ($i = 0; $i < 2000; $i++) {
    $payload = array(
        'i' => $i
    );
    $tasks[] = $client->addTask('myworker', json_encode($payload));
}
$client->runTasks();

worker.php

<?php
require_once __DIR__ . '/vendor/autoload.php';
use Monolog\Logger;
use Monolog\Handler\StreamHandler;

$worker= new GearmanWorker();
$worker->addServer("127.0.0.1", "4730");
$worker->addFunction("myworker", "something");
while ($worker->work());

function something($job) 
{      
    $payload = json_decode($job->workload());    
    // Create the logger
    $logger = new Monolog\Logger('fetch');
    $stream = new StreamHandler(__DIR__ . '/logs/error.log', Logger::DEBUG);
    $logger->pushHandler($stream);
    $logger->addInfo($payload->i);
    return json_encode($payload);
}

@harikt commented on GitHub (Dec 2, 2013): Tested with client and worker . Seems something else is wrong. So closing the issue. `client.php` ``` php <?php $client = new GearmanClient(); $client->addServer("127.0.0.1", "4730"); $client->setCompleteCallback(function ($task) { $data = $task->data(); echo "task completed " . PHP_EOL; }); for ($i = 0; $i < 2000; $i++) { $payload = array( 'i' => $i ); $tasks[] = $client->addTask('myworker', json_encode($payload)); } $client->runTasks(); ``` `worker.php` ``` php <?php require_once __DIR__ . '/vendor/autoload.php'; use Monolog\Logger; use Monolog\Handler\StreamHandler; $worker= new GearmanWorker(); $worker->addServer("127.0.0.1", "4730"); $worker->addFunction("myworker", "something"); while ($worker->work()); function something($job) { $payload = json_decode($job->workload()); // Create the logger $logger = new Monolog\Logger('fetch'); $stream = new StreamHandler(__DIR__ . '/logs/error.log', Logger::DEBUG); $logger->pushHandler($stream); $logger->addInfo($payload->i); return json_encode($payload); } ```