صفحة 300 - كتاب إنترنت الأشياء - الصف 11 - الفصل 1 - المملكة العربية السعودية

📚 تحديث البيانات والجزء الرئيسي للبرنامج (صفحة 300)

المفاهيم الأساسية

تحديث ملف البيانات: عملية إلحاق كائن التقرير الجديد بمصفوفة الكائنات الموجودة في ملف JSON، ثم كتابة المصفوفة المحدثة إلى الملف.

خريطة المفاهيم

```markmap

تحديث البيانات والجزء الرئيسي للبرنامج (صفحة 300)

تحديث محتويات ملف البيانات

العملية:

#### إلحاق كائن التقرير (report) بمصفوفة data_file_objects.

#### كتابة مصفوفة data_file_objects المحدثة إلى ملف JSON.

#### إلحاق كائن التقرير بمصفوفة reports.

#### تفريغ مصفوفة messages_stack.

الجزء الرئيسي للبرنامج

العملية:

#### التحقق من وجود ملف البيانات (data.json) قبل قراءته.

#### قراءة محتويات ملف JSON وتخزينها في data_file_objects.

#### تهيئة عميل MQTT.

#### ربط معالج الأحداث on_connect بالدالة المناسبة.

#### ربط معالج الأحداث on_message بالدالة المناسبة.

#### الاتصال بوسيط MQTT باستخدام العنوان والمنفذ.

#### الاشتراك في الموضوع المحدد (TOPIC).

#### الاستماع بشكل مستمر للرسائل الواردة (loop_forever).

```

نقاط مهمة

• يتم إنشاء كائن التقرير (`report`) الذي يحتوي على `id` و `garbage_drops` و `time_to_fill`.
• يتم إلحاق هذا الكائن أولاً بمصفوفة `data_file_objects` ثم كتابة المصفوفة كاملة إلى ملف JSON.
• يتم إلحاق التقرير أيضاً بمصفوفة `reports` المحلية وتفريغ `messages_stack` للبدء بدورة جديدة.
• في الجزء الرئيسي، يتم التحقق من وجود ملف البيانات وقراءته قبل تهيئة عميل MQTT وبدء الاستماع للرسائل.

time_to_fill = time_delta.total_seconds() / 60 report_id = len(reports) # This will be used for object indexing # The JSON object that will be appended to the JSON data file report = { "id": report_id, "garbage_drops": garbage_drops, "time_to_fill": time_to_fill } # Append the new report to the objects of the data file # and write the data_file_objects array to the data file data_file_objects.append(report) with open(data_file, 'w') as file: json.dump(data_file_objects, file, indent=4, separators=(' ,', ': ')) # Append the report object to the reports array and to the JSON data file # and clear the messages stack reports.append(report) messages_stack = [] # Check if the data file exists if path.isfile(data_file) is False: raise Exception("Data file not found") # Read the contents of the JSON data file with open(data_file, 'r') as fp: data_file_objects = json.load(fp) client = mqtt.Client(CLIENT_ID) # Initialize an MQTT client client.on_connect = on_connect # Bind the on_connect event handler client.on_message = on_message # Bind the on_message event handler client.connect(MQTT_BROKER, PORT) # Connect on the specified MQTT broker client.subscribe(TOPIC, 0) # Subscribe to the specified topic client.loop_forever() # Listen continuously for messages

وزارة التعليم Ministry of Education 2025 - 1447

300

time_to_fill = time_delta.total_seconds() / 60 report_id = len(reports) # This will be used for object indexing # The JSON object that will be appended to the JSON data file report = { "id": report_id, "garbage_drops": garbage_drops, "time_to_fill": time_to_fill } # Append the new report to the objects of the data file # and write the data_file_objects array to the data file data_file_objects.append(report) with open(data_file, 'w') as file: json.dump(data_file_objects, file, indent=4, separators=(' ,', ': ')) # Append the report object to the reports array and to the JSON data file # and clear the messages stack reports.append(report) messages_stack = [] # Check if the data file exists if path.isfile(data_file) is False: raise Exception("Data file not found") # Read the contents of the JSON data file with open(data_file, 'r') as fp: data_file_objects = json.load(fp) client = mqtt.Client(CLIENT_ID) # Initialize an MQTT client client.on_connect = on_connect # Bind the on_connect event handler client.on_message = on_message # Bind the on_message event handler client.connect(MQTT_BROKER, PORT) # Connect on the specified MQTT broker client.subscribe(TOPIC, 0) # Subscribe to the specified topic client.loop_forever() # Listen continuously for messages وزارة التعليم Ministry of Education 2025 - 1447 300