Redis Pub/Sub 및 Pulsetracker를 사용하여 Django에서 동적 위치 추적 시스템 구축

이 글에서는 Pulsetracker의 Redis Pub/Sub를 Django 애플리케이션에 통합하여 실시간 위치 업데이트를 수신하는 방법을 보여드리겠습니다. 또한 매초마다 위치 업데이트를 Pulsetracker로 보내는 간단한 JavaScript WebSocket 클라이언트를 구축하여 서비스가 실제 애플리케이션에서 어떻게 활용될 수 있는지 보여줄 것입니다.

---

왜 장고인가?

Django는 신속한 개발과 깔끔하고 실용적인 디자인을 장려하는 고급 Python 웹 프레임워크입니다. 강력한 웹 애플리케이션을 더 빠르고 쉽게 구축할 수 있는 확장성, 보안 및 풍부한 도구 생태계로 잘 알려져 있습니다.

Pulsetracker의 Redis Pub/Sub 기능은 Django와 완벽하게 통합되어 개발자가 실시간 위치 데이터를 효율적으로 수신하고 처리할 수 있습니다.

---

Django에서 Redis Pub/Sub 설정

1. 필요한 패키지 설치

먼저 Django에 대한 Redis 지원을 설치합니다.

pip install django-redis
pip install redis

---

2. Django에서 Redis 구성

Pulsetracker Redis 연결을 포함하도록 settings.py 파일을 업데이트하세요.

# settings.py

from decouple import config  # Recommended for managing environment variables

# Redis settings
PULSETRACKER_REDIS_URL = config('PULSETRACKER_REDIS_URL', default='redis://redis-sub.pulsestracker.com:6378')

---

3. 구독자 관리 명령어 생성

Django 관리 명령은 장기 실행 백그라운드 작업을 처리하는 훌륭한 방법입니다.

Django 앱에서 새 사용자 정의 명령을 만듭니다.

python manage.py startapp tracker

앱 내부에 다음 폴더와 파일 구조를 만듭니다.

tracker/
    management/
        commands/
            subscribe_pulsetracker.py

subscribe_pulsetracker.py의 코드는 다음과 같습니다.

import redis
import hashlib
import hmac
from django.core.management.base import BaseCommand

class Command(BaseCommand):
    help = "Subscribe to Pulsetracker Redis Pub/Sub server"

    def generate_signature(self, app_key, token):
        if "|" not in token:
            raise ValueError("Invalid token format")

        token_hash = hashlib.sha256(token.split("|")[1].encode()).hexdigest()
        return hmac.new(token_hash.encode(), app_key.encode(), hashlib.sha256).hexdigest()

    def handle(self, *args, **options):
        app_key = 'your_app_key_here'
        token = 'your_token_here'
        signature = self.generate_signature(app_key, token)

        channel = f"app:{app_key}.{signature}"
        redis_connection = redis.StrictRedis.from_url('redis://redis-sub.pulsestracker.com:6378')

        print(f"Subscribed to {channel}")
        pubsub = redis_connection.pubsub()
        pubsub.subscribe(channel)

        for message in pubsub.listen():
            if message['type'] == 'message':
                print(f"Received: {message['data'].decode('utf-8')}")

다음을 사용하여 구독자를 실행하세요.

python manage.py subscribe_pulsetracker

구독자가 프로덕션에서 지속적으로 실행되도록 하려면 Supervisor 또는 Django-Q와 같은 프로세스 관리자를 사용하세요.

---

백그라운드 작업에 Django-Q 사용

Django-Q 설치:

pip install django-q

settings.py 업데이트:

# settings.py

Q_CLUSTER = {
    'name': 'Django-Q',
    'workers': 4,
    'recycle': 500,
    'timeout': 60,
    'redis': {
        'host': 'redis-sub.pulsestracker.com',
        'port': 6378,
        'db': 0,
    }
}

tasks.py에서 Pulsetracker 업데이트를 수신하는 작업 만들기:

from django_q.tasks import async_task
import redis

def pulsetracker_subscribe():
    app_key = 'your_app_key_here'
    token = 'your_token_here'
    channel = f"app:{app_key}.{generate_signature(app_key, token)}"

    redis_connection = redis.StrictRedis.from_url('redis://redis-sub.pulsestracker.com:6378')
    pubsub = redis_connection.pubsub()
    pubsub.subscribe(channel)

    for message in pubsub.listen():
        if message['type'] == 'message':
            print(f"Received: {message['data'].decode('utf-8')}")

---

WebSocket 클라이언트 예

다음은 WebSocket을 통해 Pulsetracker로 전송된 장치 위치 업데이트를 시뮬레이션하는 간단한 JavaScript 클라이언트입니다.

var wsServer = 'wss://ws-tracking.pulsestracker.com';
var websocket = new WebSocket(wsServer);
const appId = 'YOUR_APP_KEY';
const clientId = 'YOUR_CLIENT_KEY';

websocket.onopen = function(evt) {
    console.log("Connected to WebSocket server.");
    // Send location every 2 seconds
    setInterval(() => {
        if (websocket.readyState === WebSocket.OPEN) {
            navigator.geolocation.getCurrentPosition((position) => {
                console.log(position);
                const locationData = {
                    appId: appId,
                    clientId: clientId,
                    data: {
                        type: "Point",
                        coordinates: [position.coords.longitude, position.coords.latitude]
                    },
                    extra: {
                        key: "value"
                    }
                };


                // Send location data as JSON
                websocket.send(JSON.stringify(locationData));
                console.log('Location sent:', locationData);
            }, (error) => {
                console.error('Error getting location:', error);
            });
        }
    }, 3000); // Every 2 seconds
};

websocket.onclose = function(evt) {
    console.log("Disconnected");
};

websocket.onmessage = function(evt) {
    if (event.data === 'Pong') {
        console.log('Received Pong from server');
    } else {
        // Handle other messages
        console.log('Received:', event.data);
    }
};

websocket.onerror = function(evt, e) {
    console.log('Error occurred: ' + evt.data);
};

---

결론

Django 및 Redis Pub/Sub와 결합된 Pulsetracker는 실시간 위치 추적을 위한 강력한 솔루션을 제공합니다. 이러한 통합을 통해 개발자는 실시간 위치 데이터를 효율적으로 처리하는 확장 가능하고 생산 가능한 시스템을 구축할 수 있습니다. WebSocket 클라이언트의 추가는 Pulsetracker가 프런트엔드 애플리케이션에 얼마나 쉽게 통합되어 사용자 경험을 향상시킬 수 있는지를 보여줍니다.

지금 Django 프로젝트에 Pulsetracker를 구현해보고 경험을 공유해 보세요! 자세한 내용은 Pulsetracker 설명서를 참조하세요.

위 내용은 Redis Pub/Sub 및 Pulsetracker를 사용하여 Django에서 동적 위치 추적 시스템 구축의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!