Pulsetracker, Laravel 및 Python을 사용하여 실시간 위치 추적 솔루션 구축

소개: PulseTracker란 무엇입니까?

Pulsetracker는 독점 SDK나 인프라에 얽매이지 않고 위치 데이터를 모니터링하기 위한 강력하고 유연한 방법이 필요한 개발자를 위해 특별히 설계된 실시간 위치 추적용 백엔드 서비스입니다. 이를 통해 개발자는 UDP 또는 WebSocket 프로토콜을 사용하여 자체 클라이언트 SDK를 구현할 수 있습니다. 또한 Pulsetracker는 실시간 위치 업데이트를 개발자의 백엔드로 직접 보낼 수 있으므로 실시간 추적이 필요한 애플리케이션에 강력한 선택이 됩니다.

이 튜토리얼에서는 실시간 위치 업데이트를 위한 리스너로 Python 스크립트와 함께 Pulsetracker를 사용하는 방법을 안내합니다. Python 스크립트는 업데이트를 수신하고 이를 Redis를 통해 Laravel 작업 핸들러에 전달하는 Pulsetracker 리스너 역할을 하여 Laravel이 이러한 업데이트를 효율적으로 처리할 수 있도록 합니다.

전제조건

1.Pulsetracker 계정: Pulsetracker 계정을 설정하고 앱 키와 인증 토큰을 받으세요.

2.Redis: Redis가 설치되어 실행 중인지 확인하세요.

3.Laravel 프로젝트: 아직 Laravel 프로젝트가 없다면 설정하세요.

프로젝트 설정

이 설정에는 두 가지 주요 구성 요소가 포함됩니다.

1.Python 스크립트: Pulsetracker에서 위치 업데이트를 수신합니다.

2.Laravel Job: Python 스크립트로부터 받은 위치 데이터를 처리합니다.

1단계: Python 스크립트 설정

Python 스크립트는 Pulsetracker의 Pusher 서비스에 연결하고 위치 업데이트를 수신한 후 Laravel이 처리할 수 있도록 Redis 대기열에 푸시합니다.

#!/usr/bin/env python

import sys
sys.path.append('..')
import pysher
import time
import logging
import redis
import json 
import uuid

global pusher
global redis

def channel_callback(data):
    messageBody = json.dumps({
        "uuid": str(uuid.uuid4()),
        "displayName": "App\Jobs\PulseLocationUpdatedJob",
        "job": "App\Jobs\PulseLocationUpdatedJob@handle",
        "data": json.loads(data),
        "maxTries": 0,
        "attempts": 0
    })
    # YOUR_APP_NAME_database_queues:QUEUE_NAME
    redis.rpush("pulsetracker_database_queues:geopulse", messageBody)

def connect_handler(data):
    channel = pusher.subscribe("private-apps.<your_app_id>")
    channel.bind('App\Events\DeviceLocationUpdated', channel_callback)

if __name__ == '__main__':

    appkey = "<pusher_app_key_in_our_documentation>"
    auth_endpoint = "https://www.pulsestracker.com/api/broadcasting/auth"

    pusher = pysher.Pusher(
        key=appkey,
        auth_endpoint_headers={            
                "Authorization": "Bearer <your_token>"
        },
        auth_endpoint=auth_endpoint,
        custom_host="pusher.pulsestracker.com",
        secure=True,
    )

    redis = redis.Redis(host='127.0.0.1', port=6379, db=0, password="<your_redis_password>")

    pusher.connection.ping_interval = 30
    pusher.connect()

    pusher.connection.bind('pusher:connection_established', connect_handler)

    while True:
        time.sleep(1)

이 스크립트의 내용:

channel_callback 함수는 위치 업데이트를 Redis 대기열에 푸시합니다.

connect_handler 함수는 특정 Pulsetracker 채널을 구독하고 이를 DeviceLocationUpdated 이벤트에 바인딩합니다.

이 스크립트는 업데이트를 수신하고 Laravel용 Redis에 전달하기 위해 지속적으로 실행되어야 합니다

2단계: Laravel 구성

이제 Python 스크립트에서 받은 업데이트를 처리할 Laravel 작업 클래스를 만들어 보겠습니다.

Laravel 작업: PulseLocationUpdatedJob

Laravel에서 작업 클래스는 Python 리스너에 의해 Redis 대기열로 푸시된 데이터를 처리합니다. PulseLocationUpdatedJob 클래스는 다음과 같습니다.

<?php

namespace App\Jobs;

use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;

class PulseLocationUpdatedJob implements ShouldQueue
{
    use Queueable;

    /**
     * Create a new job instance.
     */
    public function __construct()
    {
        //
    }

    /**
     * Execute the job.
     */
    public function handle($job, array $data)
    {
        // Handle the data here, e.g., save to the database
        var_dump($data);

        return $job->delete();
    }
}

Laravel 대기열 작업자를 시작하여 작업 처리를 시작하세요.

php artisan queue:work --queue=geopulse

결과

결론

이 설정에서 Python 리스너는 실시간 위치 데이터를 Pulsetracker에서 Laravel이 백그라운드 작업으로 처리하는 Redis 대기열로 효율적으로 스트리밍합니다. 이 접근 방식을 사용하면 Laravel이 데이터 지속성 및 백엔드 작업에 집중하는 동시에 대량의 실시간 데이터를 처리할 수 있습니다.

자료 :
https://fly.io/laravel-bytes/queues-with-other-언어s/

위 내용은 Pulsetracker, Laravel 및 Python을 사용하여 실시간 위치 추적 솔루션 구축의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!