Logger
This commit is contained in:
parent
777b4e4835
commit
047d66cbc3
|
|
@ -1,15 +1,15 @@
|
||||||
import requests
|
import requests
|
||||||
from django.db import connection
|
# from django.db import connection
|
||||||
from django.db.models import Q
|
from django.db.models import Q
|
||||||
from django.db.models.signals import post_save, pre_save
|
from django.db.models.signals import post_save, pre_save
|
||||||
from django.dispatch import receiver
|
from django.dispatch import receiver
|
||||||
from django.utils import timezone
|
# from django.utils import timezone
|
||||||
|
|
||||||
from ApiBillet.thread_mailer import ThreadMaileur
|
# from ApiBillet.thread_mailer import ThreadMaileur
|
||||||
from BaseBillet.models import Reservation, LigneArticle, Ticket, Product, Configuration, Paiement_stripe
|
from BaseBillet.models import Reservation, LigneArticle, Ticket, Product, Configuration, Paiement_stripe
|
||||||
from BaseBillet.tasks import ticket_celery_mailer
|
from BaseBillet.tasks import ticket_celery_mailer
|
||||||
|
|
||||||
from TiBillet import settings
|
# from TiBillet import settings
|
||||||
|
|
||||||
import logging
|
import logging
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
|
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import base64
|
# import base64
|
||||||
import os
|
import os
|
||||||
from io import BytesIO
|
from io import BytesIO
|
||||||
import segno
|
import segno
|
||||||
|
|
@ -14,8 +14,9 @@ from BaseBillet.models import Configuration, Reservation, Ticket
|
||||||
from TiBillet.celery import app
|
from TiBillet.celery import app
|
||||||
|
|
||||||
import logging
|
import logging
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
# from celery.utils.log import get_task_logger
|
||||||
|
# logger = get_task_logger(__name__)
|
||||||
|
|
||||||
|
|
||||||
class CeleryMailerClass():
|
class CeleryMailerClass():
|
||||||
|
|
@ -55,7 +56,7 @@ class CeleryMailerClass():
|
||||||
|
|
||||||
def send(self):
|
def send(self):
|
||||||
if self.html and self.config_valid():
|
if self.html and self.config_valid():
|
||||||
logger.info(f' send_mail')
|
logger.info(f' WORKDER CELERY : send_mail')
|
||||||
mail = EmailMultiAlternatives(
|
mail = EmailMultiAlternatives(
|
||||||
self.title,
|
self.title,
|
||||||
self.text,
|
self.text,
|
||||||
|
|
@ -72,9 +73,9 @@ class CeleryMailerClass():
|
||||||
|
|
||||||
if mail_return == 1:
|
if mail_return == 1:
|
||||||
self.sended = True
|
self.sended = True
|
||||||
logger.info(f' mail envoyé : {mail_return} - {self.email}')
|
logger.info(f' WORKDER CELERY mail envoyé : {mail_return} - {self.email}')
|
||||||
else:
|
else:
|
||||||
logger.error(f' mail non envoyé : {mail_return} - {self.email}')
|
logger.error(f' WORKDER CELERY mail non envoyé : {mail_return} - {self.email}')
|
||||||
|
|
||||||
return mail_return
|
return mail_return
|
||||||
else:
|
else:
|
||||||
|
|
@ -149,7 +150,7 @@ def create_ticket_pdf(ticket: Ticket):
|
||||||
|
|
||||||
@app.task
|
@app.task
|
||||||
def ticket_celery_mailer(reservation_uuid: str):
|
def ticket_celery_mailer(reservation_uuid: str):
|
||||||
|
logger.info(f' WORKDER CELERY app.task ticket_celery_mailer : {reservation_uuid}')
|
||||||
config = Configuration.get_solo()
|
config = Configuration.get_solo()
|
||||||
reservation = Reservation.objects.get(pk=reservation_uuid)
|
reservation = Reservation.objects.get(pk=reservation_uuid)
|
||||||
|
|
||||||
|
|
@ -179,3 +180,11 @@ def ticket_celery_mailer(reservation_uuid: str):
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"{timezone.now()} Erreur envoie de mail pour reservation {reservation} : {e}")
|
logger.error(f"{timezone.now()} Erreur envoie de mail pour reservation {reservation} : {e}")
|
||||||
raise Exception
|
raise Exception
|
||||||
|
|
||||||
|
|
||||||
|
@app.task
|
||||||
|
def test_logger():
|
||||||
|
logger.debug(f"{timezone.now()} debug")
|
||||||
|
logger.info(f"{timezone.now()} info")
|
||||||
|
logger.warning(f"{timezone.now()} warning")
|
||||||
|
logger.error(f"{timezone.now()} error")
|
||||||
|
|
@ -1,28 +1,6 @@
|
||||||
'''
|
|
||||||
|
|
||||||
import os
|
|
||||||
from celery import Celery
|
|
||||||
|
|
||||||
# setting the Django settings module.
|
|
||||||
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'TiBillet.settings')
|
|
||||||
app = Celery('TiBillet')
|
|
||||||
|
|
||||||
app.config_from_object('django.conf:settings', namespace='CELERY')
|
|
||||||
# Looks up for task modules in Django applications and loads them
|
|
||||||
app.autodiscover_tasks()
|
|
||||||
|
|
||||||
|
|
||||||
'''
|
|
||||||
|
|
||||||
'''
|
|
||||||
celery -A TiBillet worker -l INFO
|
|
||||||
from TiBillet.celery import my_task
|
|
||||||
my_task.delay()
|
|
||||||
'''
|
|
||||||
|
|
||||||
import os
|
import os
|
||||||
from django.db import connection
|
from django.db import connection
|
||||||
|
from celery.signals import setup_logging
|
||||||
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'TiBillet.settings')
|
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'TiBillet.settings')
|
||||||
|
|
||||||
from django.conf import settings
|
from django.conf import settings
|
||||||
|
|
@ -33,6 +11,11 @@ app = TenantAwareCeleryApp()
|
||||||
app.config_from_object('django.conf:settings')
|
app.config_from_object('django.conf:settings')
|
||||||
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
|
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
|
||||||
|
|
||||||
|
@setup_logging.connect
|
||||||
|
def config_loggers(*args, **kwags):
|
||||||
|
from logging.config import dictConfig
|
||||||
|
from django.conf import settings
|
||||||
|
dictConfig(settings.LOGGING)
|
||||||
|
|
||||||
@app.task
|
@app.task
|
||||||
def add(x, y):
|
def add(x, y):
|
||||||
|
|
|
||||||
|
|
@ -230,19 +230,27 @@ JET_CHANGE_FORM_SIBLING_LINKS = False
|
||||||
LOGGING = {
|
LOGGING = {
|
||||||
'version': 1,
|
'version': 1,
|
||||||
'disable_existing_loggers': False,
|
'disable_existing_loggers': False,
|
||||||
|
'formatters': {
|
||||||
|
'simple': {
|
||||||
|
'format': '%(levelname)s %(message)s',
|
||||||
|
'datefmt': '%y %b %d, %H:%M:%S',
|
||||||
|
},
|
||||||
|
},
|
||||||
'handlers': {
|
'handlers': {
|
||||||
'console': {
|
'console': {
|
||||||
'level': 'INFO',
|
'level': 'DEBUG',
|
||||||
'class': 'logging.StreamHandler',
|
'class': 'logging.StreamHandler',
|
||||||
},
|
},
|
||||||
'logfile': {
|
'logfile': {
|
||||||
'level': 'INFO',
|
'level': 'DEBUG',
|
||||||
'class': 'logging.FileHandler',
|
'class': 'logging.handlers.RotatingFileHandler',
|
||||||
'filename': f"{BASE_DIR}/www/Djangologfile",
|
'filename': f"{BASE_DIR}/www/Djangologfile",
|
||||||
|
'formatter': 'simple',
|
||||||
|
'maxBytes': 1024 * 1024 * 100, # 100 mb
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
'root': {
|
'root': {
|
||||||
'level': 'INFO',
|
'level': 'DEBUG',
|
||||||
'handlers': ['console', 'logfile']
|
'handlers': ['console', 'logfile']
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
Loading…
Reference in New Issue