我有脚本consumer.php(从兔子监听队列)
<?php
namespace App\Queue\Receivers;
class CronReceiver extends BaseReceiver
{
public function handle(AMQPMessage $msg): void
{
//logic
}
}
字符串
消费者可以工作很长时间(直到出现错误或强制重启)
只有这样,跟踪才会到达datadog
我想在不重新启动脚本的情况下为每个接收到的消息发送跟踪到datadog这可能吗?有人能告诉我如何做到这一点吗?
我试
public function handle(AMQPMessage $msg): void
{
$tracer = new Tracer();
$tracer->startActiveSpan('run');
\DDTrace\GlobalTracer::set($tracer);
//logic
var_dump($tracer->getActiveSpan());
$tracer->getActiveSpan()->finish();
$tracer->flush();
}
型
如果我使用这些参数,我可以在第一次迭代后立即发送跟踪,但在随后的迭代中什么也没有到达
1条答案
按热度按时间iswrvxsc1#
我让它工作。我使用datadog/dd-trace库
现在我的代码看起来像这样:
字符串
现在我将脚本的每次迭代作为单独的跟踪
x1c 0d1x的数据