3 changed files with 17 additions and 81 deletions
-
76app/Commons/TencentMap.php
-
19app/Service/v3/Implementations/LocationService.php
-
3config/config.php
@ -1,76 +0,0 @@ |
|||||
<?php |
|
||||
|
|
||||
namespace App\Commons; |
|
||||
use Hyperf\Guzzle\ClientFactory; |
|
||||
|
|
||||
class TencentMap |
|
||||
{ |
|
||||
/** |
|
||||
* @var \Hyperf\Guzzle\ClientFactory |
|
||||
*/ |
|
||||
private $clientFactory; |
|
||||
|
|
||||
public function __construct(ClientFactory $clientFactory) |
|
||||
{ |
|
||||
$this->clientFactory = $clientFactory; |
|
||||
} |
|
||||
|
|
||||
public function getClient() |
|
||||
{ |
|
||||
// $options 等同于 GuzzleHttp\Client 构造函数的 $config 参数
|
|
||||
$options = [ |
|
||||
'timeout' => 2.0, |
|
||||
]; |
|
||||
// $client 为协程化的 GuzzleHttp\Client 对象
|
|
||||
$client = $this->clientFactory->create($options); |
|
||||
|
|
||||
return $client; |
|
||||
} |
|
||||
|
|
||||
public function event($labels=null,$datas){ |
|
||||
|
|
||||
co(function () use ($labels,$datas){ |
|
||||
|
|
||||
$client = $this->getClient(); |
|
||||
$kv = []; |
|
||||
foreach ($datas as $key => $value) { |
|
||||
$kv[] = $key."=".$value; |
|
||||
} |
|
||||
$pushLabels = []; |
|
||||
|
|
||||
$event_name = 'event_'.env('APP_ENV'); |
|
||||
if(!empty($labels)) $pushLabels[$event_name] = $labels; |
|
||||
|
|
||||
/* |
|
||||
* data format: |
|
||||
curl -v -H "Content-Type: application/json" -XPOST -s "http://39.96.12.39:3100/loki/api/v1/push" --data-raw \ |
|
||||
'{"streams": [{ "stream": { "foo": "bar2" }, "values": [ [ "1596274538882028800", "fizzbuzz" ] ] }]}' |
|
||||
*/ |
|
||||
$ts = $this->getMsecTime() . '000000'; |
|
||||
$datas = implode("&",$kv); |
|
||||
$values = [[$ts,$datas]]; |
|
||||
$app_name = env('APP_NAME').'_'.env('APP_ENV'); |
|
||||
|
|
||||
$pushLabels['app']= $app_name; |
|
||||
$pushDatas = [ |
|
||||
'streams'=>[ |
|
||||
[ |
|
||||
'stream'=>$pushLabels, |
|
||||
'values'=>$values, |
|
||||
] |
|
||||
] |
|
||||
]; |
|
||||
$client->post( |
|
||||
env('LOG_HOST','http://39.96.12.39:3100').'/loki/api/v1/push', |
|
||||
[ |
|
||||
'headers'=>[ |
|
||||
'Content-Type'=>'application/json' |
|
||||
], |
|
||||
'body' => json_encode($pushDatas) |
|
||||
] |
|
||||
); |
|
||||
//var_dump(json_encode($pushDatas) );
|
|
||||
}); |
|
||||
} |
|
||||
|
|
||||
} |
|
||||
Write
Preview
Loading…
Cancel
Save
Reference in new issue