پایتون - هیوادار

django channels sync async

تفاوت دو تکه کد زیر که از Django channels استفاده کرده است چیست؟

class FeedbackLockConsumer(WebsocketConsumer):
    def websocket_connect(self, event):
        doc_id = self.scope['url_route']['kwargs']['doc_id']
        user = self.scope['user']

        async_to_sync(self.channel_layer.group_add)(
            f"group_doc_{doc_id}",
            self.channel_name
        )

        self.accept()

		self.send(
			text_data=json.dumps({"message": "You are the Editor"})
		)

class FeedbackLockConsumer(WebsocketConsumer):

def websocket_connect(self, event):

doc_id = self.scope['url_route']['kwargs']['doc_id']

user = self.scope['user']

async_to_sync(self.channel_layer.group_add)(

f"group_doc_{doc_id}",

self.channel_name

)

self.accept()

self.send(

text_data=json.dumps({"message": "You are the Editor"})

)

class FeedbackLockConsumer(AsyncWebsocketConsumer):
    async def websocket_connect(self, event):
        doc_id = self.scope['url_route']['kwargs']['doc_id']
        user = self.scope['user']

        await self.channel_layer.group_add(
            f"group_doc_{doc_id}",
            self.channel_name
        )

        await self.accept()

		await self.send(
			text_data=json.dumps({"message": "You are the Editor"})
		)

class FeedbackLockConsumer(AsyncWebsocketConsumer):

async def websocket_connect(self, event):

doc_id = self.scope['url_route']['kwargs']['doc_id']

user = self.scope['user']

await self.channel_layer.group_add(

f"group_doc_{doc_id}",

self.channel_name

)

await self.accept()

await self.send(

text_data=json.dumps({"message": "You are the Editor"})

)

هر دو کد consumer هایی برای برقراری ارتباط websocket هستند. در اولی از ارتباط sync استفاده شده و در دومی از ارتباط async استفاده شده است.

در نتیجه:

در اولی:

اگر یک کانکشن برقرار شود، دیگر هیچ کانکشنی برقرار نمیشود تا کانکشن اولی بسته شود. چون کانکشن اول accept شده و هر کانکشن یک worker thread رو اشغال میکنه و تا زمانی که بسته نشه thread برای کانکشن بعدی باز نمیشه. این روش برای کارهای سریع مثل یه ارتباط با دیتابیس مناسب است اما برای یک ارتباط websocket که قرار است مدت زیادی باز بماند خوب نیست.

در دومی:

ارتباطات async است یعنی در واقع به آن گفته می شود که در قسمت await منتظر بمان تا I/O تکمیل شود اما در طول این انتظار ارتباطات دیگر می توانند برقرار شوند. در این حالت هر ارتباط به صورت یک task در event loop اجرا میشود. event loop ارتباطات دیگر را مدیریت میکند.

در واقع در حالت sync تسکها توسط worker ها انجام میشود و در حالت async تسک ها توسط event loop.

حالت sync مانند آشپزیست که هر قسمت غذا را کامل می پزد و بعد سراغ قسمت بعدی می رود اما حالت async چند ماهیتابه جلوی آشپز است که هر کدام را می چرخاند و سراغ بعدی می رود. این کار را event loop انجام می دهد که در پایتون در asyncio پیاده سازی شده است.

در دو consumer ای که نوشته شد هم داستان همین است. تا کانکشن اول بسته شود کانکشن بعدی باز نمی شود اما در حالت async این طور نیست و کانکشن اول در قسمت await وای میسه و event loop سراغ کانکشن های بعدی می رود.

کی از Message Queue استفاده میکنیم؟ وقتی که قرار باشد پیامی بین process ها یا consumer ها جابجا شوند. در واقع هر وقت توی django channels از channel layer بخایم استفاده کنیم باید از message q استفاده کنیم. در واقع channel layer همان message queue است.

Normalization vs Denormalization

کلاسهای زیر را در نظر بگیرید. این مدل طراحی مشکلات زیادی به وجوده میاره. با آپدیت شدن کلاس اول مجبور هستیم کلاس دوم و سوم رو هم آپدیت کنیم که با فراموش این نکته توی قسمت های مختلف کد باگهای زیادی ایجاد میشه. و همین آپدیت های اضافی کدهای اضافی در نتیجه باگهای بیشتر و سرعت کمتر رو به ارمغان میاره

depenancy زیادی بین کلاسها میبینید. در صورت آپدیت یک Service باید دو کلاس دیگر هم آپدیت شود و این موضوعی نیست که اتوماتیک انجام شود و ایراداتی در نرم افزار ایجاد میکند:

class Service(models.Model, Template):
    name = models.CharField(...)
    name_fixed = models.CharField(...)
	...
	

class Link(models.Model, Template):
    provider = models.ForeignKey(
        'Service'...)
    provider_name = models.CharField(...)
    consumer = models.ForeignKey(
        'Service',...)
    consumer_name = models.CharField(...)
	.
	.
	.
	


class Chain(models.Model):
    pc = models.CharField(...)
    provider_name = models.CharField(...)
    consumer_name = models.CharField(...)
	
	.
	.
	.

class Service(models.Model, Template):

name = models.CharField(...)

name_fixed = models.CharField(...)

...

class Link(models.Model, Template):

provider = models.ForeignKey(

'Service'...)

provider_name = models.CharField(...)

consumer = models.ForeignKey(

'Service',...)

consumer_name = models.CharField(...)

class Chain(models.Model):

pc = models.CharField(...)

provider_name = models.CharField(...)

consumer_name = models.CharField(...)

برای حل این موضوع باید کد را Normalize کنیم. یعنی تکرار به حداقل برسد و بجای تکرار اطلاعات موارد تکراری با کلید خارجی تبدیل شود:

class Service(models.Model, Template):
    name = models.CharField(...)
    name_fixed = models.CharField(...)
	...
	

class Link(models.Model, Template):
    provider = models.ForeignKey(
        'Service'...)
    
    consumer = models.ForeignKey(
        'Service',...)
    
	...
	@property
	def provider_name(self):
		return self.provider.name
		
	@property
	def consumer_name(self):
		return self.consumer.name
	
	.
	.
	.
	

class Chain(models.Model):
    pc = models.CharField(...)
	link = models.ForeignKey(Link, ...)
	...
	
	@property
	def provider_name(self):
		return self.link.provider.name
		
	@property
	def consumer_name(self):
		return self.link.consumer.name

class Service(models.Model, Template):

name = models.CharField(...)

name_fixed = models.CharField(...)

...

class Link(models.Model, Template):

provider = models.ForeignKey(

'Service'...)

consumer = models.ForeignKey(

'Service',...)

...

@property

def provider_name(self):

return self.provider.name

@property

def consumer_name(self):

return self.consumer.name

class Chain(models.Model):

pc = models.CharField(...)

link = models.ForeignKey(Link, ...)

...

@property

def provider_name(self):

return self.link.provider.name

@property

def consumer_name(self):

return self.link.consumer.name

حالا با آپدیت هر سرویس دو کلاس دیگر به صورت اتوماتیک آپدیت هستند.

گاهی Denormalization به درد میخورد. وقتی میخایم از یک جدول گزارشگیری داشته باشیم و نیاز به Join نباشد تکرار اطلاعات باعث افزایش بهره وری query می شود و …

پر کردن مودال با استفاده از اطلاعات فرم

نیاز بود که توی یک جدول اگر توی سلول یکی از ستونها کلیک کردیم یک مودال باز بشود. اما باید اطلاعاتی مربوط به آن ردیف به مودال پاس بدیم. متوجه شدم که این اطلاعات مربوط به ردیف مذکور را میتوان به عنوان یک پایامتر به سلول مربوطه اضافه کرد مثل:

<tbody>
	{% for f in feedbacks %}
		<tr>
			<td
				{% if f.active %} class="text-danger" {% endif %}
			>
				{% if f.active %} (فعال) {% endif %}v.{{f.feedback_version}}
			</td>
			<td>{{f.feedback_date}}</td>
			<td>{{f.user}}</td>
			<td>
				<div class="row">
					<div class="col-4">
						<a
							href="#"
							data-version="{{ f.feedback_version }}"
							main_points="{{ f.main_points|escape }}"
							secondary_points="{{ f.secondary_points|escape }}"
							guids="{{ f.guids_and_recommendations|escape }}"
							feedback_id="{{ f.id }}"
							feedback_version="{{ f.feedback_version }}"
							class="open-modal"
							style="cursor: pointer;"
						>
							جزئیات
						</a>
					</div>
				</div>
			</td>
		</tr>
	{% endfor %}
</tbody>

<tbody>

{% for f in feedbacks %}

<tr>

<td

{% if f.active %} class="text-danger" {% endif %}

{% if f.active %} (فعال) {% endif %}v.{{f.feedback_version}}

</td>

<td>{{f.feedback_date}}</td>

<td>

href="#"

data-version="{{ f.feedback_version }}"

main_points="{{ f.main_points|escape }}"

secondary_points="{{ f.secondary_points|escape }}"

guids="{{ f.guids_and_recommendations|escape }}"

feedback_id="{{ f.id }}"

feedback_version="{{ f.feedback_version }}"

class="open-modal"

style="cursor: pointer;"

جزئیات

</a>

</div>

</td>

</tr>

{% endfor %}

</tbody>

توی خود مودال یک سری فیلد خالی تعریف میکنیم که بعدا با جاواساکریپ اطلاعات پارامترها رو به اون اضافه کنیم:

{% block modals %}
    <div id="mapModal" class="modal fade" tabindex="-1" aria-labelledby="#mapModalLabel" aria-hidden="true">
        <div class="modal-dialog">
            <div class="modal-content">
                <div class="modal-header">
                    <h5 class="modal-title" id="mapModalLabel">
                        جزئیات
                    </h5>
                    <button type="button" class="btn-close" data-bs-dismiss="modal" aria-label="Close"></button>
                </div>
                <div class="modal-body">
                    <p><strong>نسخه:</strong> <span id="modal-version"></span></p>
                    <p><strong>نکات اصلی:</strong> <span id="main_points"></span></p>
                    <p><strong>نکات فرعی:</strong> <span id="secondary_points"></span></p>
                    <p><strong>راهنماییها:</strong> <span id="guids"></span></p>
                </div>
                <div class="modal-footer">
                    <a href="#" data-bs-dismiss="modal">بستن</a>
                    <a id="activation_btn">
                        فعالسازی
                    </a>
                </div>
            </div>
        </div>
    </div>
{% endblock %}

{% block modals %}

جزئیات

</h5>

</div>

<p><strong>راهنماییها:</strong> <span id="guids"></span></p>

</div>

فعالسازی

</a>

</div>

{% endblock %}

الان توی اسکریپت زیر از هر ردیف سلول مربوطه رو بر اساس اسم کلاس میگیریم. بعد از اون سلول پارامترم مربوطه که دیتا بهش وصل شده رو بر میداریم بعد همون مقدارها رو به مودال میدیم:

<script>
	document.addEventListener('DOMContentLoaded', function () {
		document.querySelectorAll('.open-modal').forEach(function (cell) {
			cell.addEventListener('click', function () {
				const version = this.getAttribute('data-version');
				const main_points = this.getAttribute('main_points');
				const secondary_points = this.getAttribute('secondary_points');
				const guids = this.getAttribute('guids');
				const feedback_version = this.getAttribute('feedback_version');
				const feedback_id = this.getAttribute('feedback_id');

				document.getElementById('modal-version').textContent = version;
				document.getElementById('main_points').innerHTML  = main_points;
				document.getElementById('secondary_points').innerHTML  = secondary_points;
				document.getElementById('guids').innerHTML  = guids;
				document.getElementById('activation_btn').href = "/man/documents/versionactivate/"+feedback_id+"/"+feedback_version+"/";

				const mapModal = new bootstrap.Modal(document.getElementById('mapModal'));
				mapModal.show();
			});
		});
	});
</script>

document.addEventListener('DOMContentLoaded', function () {

document.querySelectorAll('.open-modal').forEach(function (cell) {

cell.addEventListener('click', function () {

const version = this.getAttribute('data-version');

const main_points = this.getAttribute('main_points');

const secondary_points = this.getAttribute('secondary_points');

const guids = this.getAttribute('guids');

const feedback_version = this.getAttribute('feedback_version');

const feedback_id = this.getAttribute('feedback_id');

document.getElementById('modal-version').textContent = version;

document.getElementById('main_points').innerHTML = main_points;

document.getElementById('secondary_points').innerHTML = secondary_points;

document.getElementById('guids').innerHTML = guids;

document.getElementById('activation_btn').href = "/man/documents/versionactivate/"+feedback_id+"/"+feedback_version+"/";

const mapModal = new bootstrap.Modal(document.getElementById('mapModal'));

mapModal.show();

});

</script>

annotate و عدم اعمال Index

این 2 کد را در نظر بگیرید:

Service.objects.annotate(
		cnt_p=Count('provided_links'), cnt_c=Count('consumed_links')
	).exclude(Q(cnt_p=0, cnt_c=0), st=2)

Service.objects.annotate(

cnt_p=Count('provided_links'), cnt_c=Count('consumed_links')

).exclude(Q(cnt_p=0, cnt_c=0), st=2)

Service.objects.exclude(st=2).annotate(
	cnt_p=Count('provided_links'), cnt_c=Count('consumed_links')
).exclude(cnt_p=0, cnt_c=0)

Service.objects.exclude(st=2).annotate(

cnt_p=Count('provided_links'), cnt_c=Count('consumed_links')

).exclude(cnt_p=0, cnt_c=0)

با تبدیل اولی به دومی زمان این query از 450 میلی ثانیه به 45 میلی ثانیه کاهش پیدا کرد. چرا؟

دلیل این بود که فیلدهای این مدل همگی Index بودند اما این ایندکسها اعمال نمی شدند چونکه annotate باعث میشود که کل جدول اسکن شود و عملا ایندکسها بی فایده باشند بنابراین حداقل st=0 را به قبل از annotate انتقال دادیم و این باعث شد برای annotate که اتفاقا از WHERE استفاده میکند از ایندکس استفاده شود.

مقایسه دو تکه کد

تفاوت دو کد زیر چیست و کدام بهتر است؟

class MagAttachment(models.Model):
    file = models.FileField(upload_to='mag/attachments', verbose_name='فایل اصلی')
    thumbnail = models.ImageField(upload_to='mag/attachments', verbose_name="نمایه", blank=True, null=True)

    def __str__(self):
        return str(self.file.name)

    def delete(self, *args, **kwargs):
        if self.file:
            self.file.delete(save=False)

        if self.thumbnail:
            self.thumbnail.delete(save=False)

        super().delete(*args, **kwargs)

    def get_thumbnail_url(self):
        if self.thumbnail:
            return self.thumbnail.url
        return static('images/placeholder.PNG')

class MagAttachment(models.Model):

file = models.FileField(upload_to='mag/attachments', verbose_name='فایل اصلی')

thumbnail = models.ImageField(upload_to='mag/attachments', verbose_name="نمایه", blank=True, null=True)

def __str__(self):

return str(self.file.name)

def delete(self, *args, **kwargs):

if self.file:

self.file.delete(save=False)

if self.thumbnail:

self.thumbnail.delete(save=False)

super().delete(*args, **kwargs)

def get_thumbnail_url(self):

if self.thumbnail:

return self.thumbnail.url

return static('images/placeholder.PNG')

class MagAttachment(models.Model):
    file = models.FileField(upload_to='mag/attachments', verbose_name='فایل اصلی')
    thumbnail = models.ImageField(upload_to='mag/attachments', verbose_name="نمایه", default='mag/placeholder.JPG')

    def __str__(self):
        return str(self.file.name)

    def delete(self, *args, **kwargs):
        if self.file:
            self.file.delete(save=False)

        if self.thumbnail and self.thumbnail.name != 'mag/placeholder.JPG':
            self.thumbnail.delete(save=False)

        super().delete(*args, **kwargs)

class MagAttachment(models.Model):

file = models.FileField(upload_to='mag/attachments', verbose_name='فایل اصلی')

thumbnail = models.ImageField(upload_to='mag/attachments', verbose_name="نمایه", default='mag/placeholder.JPG')

def __str__(self):

return str(self.file.name)

def delete(self, *args, **kwargs):

if self.file:

self.file.delete(save=False)

if self.thumbnail and self.thumbnail.name != 'mag/placeholder.JPG':

self.thumbnail.delete(save=False)

super().delete(*args, **kwargs)

در کد اول اگر thumbnail توسط کاربر انتخاب نشود یک فایل از مسیر mag آپلود میشود. و هنگام پاک شدن آبجکت مربوطه، اگر این آبجکت دارای این فایل پیشفرض بود پاک نشود که البته در این کد مربوطه خود به خود پاک می شود. پس یک باگ وجود دارد. گذشته از این باگ اگر 1000 بار کاربر بدون thumbnail فایل آپلود کند 1000 فایل تکراری ذخیره میشود.

در ضمن اگر فایل بهر دلیلی پاک شود یا نام آن تغییر کند سیستم دچار مشکل میشود.

در کد دوم اما اگر کاربر فایلی انتخاب نکند هیچ فایل پیش فرضی آپلود نمیشود بنابراین فایل تکراری دیده نمی شود و فضا هدر نمی روند.

از طرفی یک فایل static پاک نشده و هرکجا یک سند thumbnail نداشته باشد با متد get_thumbnail_url این فایل نشان داده میشود و دیگر سیستم دچار باگهای ناخواسته نمی شود.

تغییر queryset توی فرم جنگو

توی یک فرم میخوایم فیلدی که لیستی را به کاربر نشان میدهد را تغییری بدیم که همه مواردی که توی اون فیلد توی دیتابیس نیست را نشان ندهیم.

class MagForm(forms.ModelForm):
    class Meta:
        model = Mag
        fields = '__all__'

    def __init__(self, *args, **kwargs):
        super(MagForm, self).__init__(*args, **kwargs)
        self.fields['attachment'].queryset = MagAttachment.objects.filter(mag__isnull=True)

class MagForm(forms.ModelForm):

class Meta:

model = Mag

fields = '__all__'

def __init__(self, *args, **kwargs):

super(MagForm, self).__init__(*args, **kwargs)

self.fields['attachment'].queryset = MagAttachment.objects.filter(mag__isnull=True)

صحت سنجی فرمت فایل توی فرم جنگو

چطور توی یک فرم اگر یک فایل آپلود شده از یک فرمت خاص نبود ارور برگردونیم

class MagAttachmentForm(forms.ModelForm):
    class Meta:
        model = MagAttachment
        fields = '__all__'

    def clean_file(self):
        file = self.cleaned_data['file']
        content_type = file.content_type

        if content_type == 'application/pdf':
            return file
        else:
            raise forms.ValidationError('فرمت pdf')

class MagAttachmentForm(forms.ModelForm):

class Meta:

model = MagAttachment

fields = '__all__'

def clean_file(self):

file = self.cleaned_data['file']

content_type = file.content_type

if content_type == 'application/pdf':

return file

else:

raise forms.ValidationError('فرمت pdf')

مشکل ثبت مجدد فرم با رفرش

. توی کد زیر بعد از ثبت کردن فرم اگر صفحه را رفرش کنیم همان فرم دوباره ثبت میشود.

    if request.POST and 'comment_form_submit' in request.POST:
        feedback_comment_form = FeedbackCommentForm(request.POST)
        if feedback_comment_form.is_valid():
            body = feedback_comment_form.cleaned_data['body']
            DocumentComment.objects.create(
                document=d,
                user=request.user,
                body=body,
                comment_datetime=datetime.datetime.now()
            )

            context['comment_list'] = DocumentComment.objects.filter(document=d)
            DocumentLogger.log(request, d, 'ثبت کامنت ')
            messages.success(request, 'کامنت ثبت شد')

            return render(request, "man/documents/document-detail.html", context)

if request.POST and 'comment_form_submit' in request.POST:

feedback_comment_form = FeedbackCommentForm(request.POST)

if feedback_comment_form.is_valid():

body = feedback_comment_form.cleaned_data['body']

DocumentComment.objects.create(

document=d,

user=request.user,

body=body,

comment_datetime=datetime.datetime.now()

)

context['comment_list'] = DocumentComment.objects.filter(document=d)

DocumentLogger.log(request, d, 'ثبت کامنت ')

messages.success(request, 'کامنت ثبت شد')

return render(request, "man/documents/document-detail.html", context)

مشکل در فروم جنگو این جوری توضیح داده شده است:

یعنی بعد از POST موفق باید فرم را redirect کنیم که با این کار صفحه جدید با GET فراخوانی میشود در نتیجه اگر رفرش کنیم باز هم در خواست GET ارسال میگردد. یعنی کد را به شکل زیر تغییر میدهیم.

    if request.POST and 'comment_form_submit' in request.POST:
        feedback_comment_form = FeedbackCommentForm(request.POST)
        if feedback_comment_form.is_valid():
            body = feedback_comment_form.cleaned_data['body']
            DocumentComment.objects.create(
                document=d,
                user=request.user,
                body=body,
                comment_datetime=datetime.datetime.now()
            )

            context['comment_list'] = DocumentComment.objects.filter(document=d)
            DocumentLogger.log(request, d, 'ثبت کامنت ')
            messages.success(request, 'کامنت ثبت شد')
            url = reverse('man:management_documents_document_detail', args=[doc_id])
            return HttpResponseRedirect(url)

if request.POST and 'comment_form_submit' in request.POST:

feedback_comment_form = FeedbackCommentForm(request.POST)

if feedback_comment_form.is_valid():

body = feedback_comment_form.cleaned_data['body']

DocumentComment.objects.create(

document=d,

user=request.user,

body=body,

comment_datetime=datetime.datetime.now()

)

context['comment_list'] = DocumentComment.objects.filter(document=d)

DocumentLogger.log(request, d, 'ثبت کامنت ')

messages.success(request, 'کامنت ثبت شد')

url = reverse('man:management_documents_document_detail', args=[doc_id])

return HttpResponseRedirect(url)

serializer توی Django Rest Framework با دیتای ورودی چیکار میکنه؟

بهترین روش یادگیری یه فریم ورک خوندن کد خود فریم ورک و داکیومنت توی خود کد هست. برای serializer توی جنگو یک کامنت هست توی rest_framework/serializer.py که:

class BaseSerializer(Field):
    """
    The BaseSerializer class provides a minimal class which may be used
    for writing custom serializer implementations.

    Note that we strongly restrict the ordering of operations/properties
    that may be used on the serializer in order to enforce correct usage.

    In particular, if a `data=` argument is passed then:

    .is_valid() - Available.
    .initial_data - Available.
    .validated_data - Only available after calling `is_valid()`
    .errors - Only available after calling `is_valid()`
    .data - Only available after calling `is_valid()`

    If a `data=` argument is not passed then:

    .is_valid() - Not available.
    .initial_data - Not available.
    .validated_data - Not available.
    .errors - Not available.
    .data - Available.
    """

    def __init__(self, instance=None, data=empty, **kwargs):. . .

class BaseSerializer(Field):

"""

The BaseSerializer class provides a minimal class which may be used

for writing custom serializer implementations.

Note that we strongly restrict the ordering of operations/properties

that may be used on the serializer in order to enforce correct usage.

In particular, if a `data=` argument is passed then:

.is_valid() - Available.

.initial_data - Available.

.validated_data - Only available after calling `is_valid()`

.errors - Only available after calling `is_valid()`

.data - Only available after calling `is_valid()`

If a `data=` argument is not passed then:

.is_valid() - Not available.

.initial_data - Not available.

.validated_data - Not available.

.errors - Not available.

.data - Available.

"""

def __init__(self, instance=None, data=empty, **kwargs):. . .

خیلی خوب توضیح میده که اگر به serializer پارامتر data رو پاس داده باشیم تابع is_valid قابل استفاده است. و initial_data هم در دسترس هست که همون دیتایی هست که به API پاس داده شده. بعد از is_valid این داده ورودی به valid شده تبدیل میشه که میتونیم توی validated_data ببینیم. مثلا اگر Id به object مربوطه تبدیل میشه. و errors و data هم در دسترس خواهد بود. data درواقع اون رکورد جدیدی هست که ایجاد شده است.

مثال زیر رو ببینید:

    def create(self, request, *args, **kwargs):
        serializer = self.get_serializer(data=request.data)

        if not serializer.is_valid():
            return Response(
                {"errors": serializer.errors},
                status.HTTP_400_BAD_REQUEST
            )

        self.perform_create(serializer)

        print("-----------------------------")
        print(serializer.initial_data)
        print(serializer.validated_data)
        print(serializer.errors)
        print(serializer.data)

        create_update_related_chain(serializer.instance, False)
        return Response(serializer.data, status.HTTP_201_CREATED)

def create(self, request, *args, **kwargs):

serializer = self.get_serializer(data=request.data)

if not serializer.is_valid():

return Response(

{"errors": serializer.errors},

status.HTTP_400_BAD_REQUEST

)

self.perform_create(serializer)

print("-----------------------------")

print(serializer.initial_data)

print(serializer.validated_data)

print(serializer.errors)

print(serializer.data)

create_update_related_chain(serializer.instance, False)

return Response(serializer.data, status.HTTP_201_CREATED)

میبینید که بعد serializer.is_valid() مقادیر مربوطه رو پرینت کردم.

مثال خروجی هم در ادامه میبینید:

-----------------------------
{'provider': 159, 'consumer': 156, 'interface': 164, 'interface2': 161, 'protocol': 2, 'lt': 0, 'description': '', 'api': '', 'frequency': 0, 'ProviderVerified': False, 'ConsumerVerified': False, 'ESBVerified': False, 'api_gateway': False, 'active': False}
OrderedDict({'provider': <Service: Active probe(pixip)>, 'consumer': <Service: AOTA(hasin)>, 'interface': <Service: Behsa Proxy(external)>, 'interface2': <Service: GFEP(external)>, 'protocol': <Protocol: SFTP>, 'lt': 0, 'description': '', 'api': '', 'frequency': 0.0, 'ProviderVerified': False, 'ConsumerVerified': False, 'ESBVerified': False, 'api_gateway': False, 'active': False})
{}
{'id': 1303, 'provider': 159, 'provider_name': 'active_probe', 'consumer': 156, 'consumer_name': 'aota', 'interface': 164, 'interface_name': 'behsa_proxy', 'interface2': 161, 'interface2_name': 'gfep', 'protocol': 2, 'protocol_name': 'sftp', 'lt': 0, 'lt_display': 'COMMAND', 'description': '', 'api': '', 'frequency': 0.0, 'ProviderVerified': False, 'ConsumerVerified': False, 'ESBVerified': False, 'api_gateway': False, 'active': False}

-----------------------------

{'provider': 159, 'consumer': 156, 'interface': 164, 'interface2': 161, 'protocol': 2, 'lt': 0, 'description': '', 'api': '', 'frequency': 0, 'ProviderVerified': False, 'ConsumerVerified': False, 'ESBVerified': False, 'api_gateway': False, 'active': False}

OrderedDict({'provider': <Service: Active probe(pixip)>, 'consumer': <Service: AOTA(hasin)>, 'interface': <Service: Behsa Proxy(external)>, 'interface2': <Service: GFEP(external)>, 'protocol': <Protocol: SFTP>, 'lt': 0, 'description': '', 'api': '', 'frequency': 0.0, 'ProviderVerified': False, 'ConsumerVerified': False, 'ESBVerified': False, 'api_gateway': False, 'active': False})

{}

{'id': 1303, 'provider': 159, 'provider_name': 'active_probe', 'consumer': 156, 'consumer_name': 'aota', 'interface': 164, 'interface_name': 'behsa_proxy', 'interface2': 161, 'interface2_name': 'gfep', 'protocol': 2, 'protocol_name': 'sftp', 'lt': 0, 'lt_display': 'COMMAND', 'description': '', 'api': '', 'frequency': 0.0, 'ProviderVerified': False, 'ConsumerVerified': False, 'ESBVerified': False, 'api_gateway': False, 'active': False}

بازنویسی serializer توی Django Rest Framework

توی serializer های DRF گاهی لازمه وقتی متد list() اون صدا زده میشه باید قبلش دیتایی که ازش گرفته میشه تغییری بدیم برای این کار از متد to_representaion استفاده میکنیم.

class LinkAPISerializer(serializers.ModelSerializer):
    provider_name = serializers.CharField(source='provider.name_fixed', read_only=True)
    consumer_name = serializers.CharField(source='consumer.name_fixed', read_only=True)
    interface_name = serializers.CharField(source='interface.name_fixed', read_only=True)
    interface2_name = serializers.CharField(source='interface2.name_fixed', read_only=True)
    protocol_name = serializers.CharField(source='protocol.name_fixed', read_only=True)
    lt_display = serializers.CharField(source='get_lt_display', read_only=True)

    class Meta:
        model = Link
        fields = [
            'id', 'provider', 'provider_name', 'consumer', 'consumer_name', 'interface', 'interface_name', 'interface2',
            'interface2_name', 'protocol', 'protocol_name', 'lt', 'lt_display', 'description', 'api', 'frequency',
            'ProviderVerified', 'ConsumerVerified', 'ESBVerified', 'api_gateway', 'active'
        ]

    def to_representation(self, instance):
        data = super().to_representation(instance)
        if data.get('description'):
            data['description'] = data['description'].strip('\"')

        return data

class LinkAPISerializer(serializers.ModelSerializer):

provider_name = serializers.CharField(source='provider.name_fixed', read_only=True)

consumer_name = serializers.CharField(source='consumer.name_fixed', read_only=True)

interface_name = serializers.CharField(source='interface.name_fixed', read_only=True)

interface2_name = serializers.CharField(source='interface2.name_fixed', read_only=True)

protocol_name = serializers.CharField(source='protocol.name_fixed', read_only=True)

lt_display = serializers.CharField(source='get_lt_display', read_only=True)

class Meta:

model = Link

fields = [

'id', 'provider', 'provider_name', 'consumer', 'consumer_name', 'interface', 'interface_name', 'interface2',

'interface2_name', 'protocol', 'protocol_name', 'lt', 'lt_display', 'description', 'api', 'frequency',

'ProviderVerified', 'ConsumerVerified', 'ESBVerified', 'api_gateway', 'active'

]

def to_representation(self, instance):

data = super().to_representation(instance)

if data.get('description'):

data['description'] = data['description'].strip('\"')

return data