ฉันจะแก้ไข "ขนาดหน่วยความจำที่อนุญาตหมดแล้ว" เมื่อแบตช์เสร็จสิ้นได้อย่างไร

ชุดประมวลผลรายการทั้งหมด แต่แทนที่จะแสดงข้อความเสร็จสิ้น ฉันเห็นข้อผิดพลาด "ขนาดหน่วยความจำที่อนุญาตของ 536870912 ไบต์หมดแล้ว"

เมื่อฉันดีบักโค้ด ฉันสังเกตเห็นว่า Drupal โหลดบล็อกที่ประมวลผลแต่ละบล็อกเมื่อเสร็จสิ้นแบทช์ (ContentEntityBase->__สร้าง). ฉันไม่เข้าใจว่าทำไม Drupal ถึงทำเช่นนั้น

โครงสร้างของรหัส:

นี่คือโมดูลแบบกำหนดเองที่มีคลาสฟอร์มและฟังก์ชันแบทช์ใน custom_module.module ไฟล์.เมื่อส่งแบบฟอร์ม โมดูลจะเรียกฟังก์ชันสร้างแบทช์:

ฟังก์ชันสาธารณะ submitForm (อาร์เรย์ &$form, FormStateInterface $form_state) {
  custom_module_make_batch();
}

ฟังก์ชัน custom_module_build_batch รับรหัสของบล็อกแบบกำหนดเอง (4000 หรือมากกว่า) และสร้างแบทช์:

ฟังก์ชัน custom_module_make_batch()
{

  $ชุด = [];

  $items = get_blocks_ids();

  $batch = custom_module_generate_batch($รายการ);
  batch_set($แบทช์);
}

ฟังก์ชัน custom_module_generate_batch($รายการ)
{

  $การดำเนินการ = [];

  $operations_groups = array_chunk($รายการ, 50);

  foreach ($operations_groups เป็น $key => $operations_group) {
    $การดำเนินการ[] = [
      'custom_module_batch_op',
      [$operations_group],
    ];
  }

  $ ชุด = [
    'operation' => $operation,
    'เสร็จสิ้น' => 'custom_module_batch_finished',
    'title' => 'แบทช์กำหนดเอง',
    'init_message' => 'แบทช์กำลังเริ่มต้น',
    'progress_message' => 'ประมวลผล @current จาก @total ส่วน',
    'error_message' => 'แบทช์พบข้อผิดพลาด',
  ];
  ส่งคืน $ ชุด;
}

ฟังก์ชัน custom_module_batch_op($operations_group, &$context) {

  foreach ($operations_group เป็น $key => $bid) {
  
    $block = \Drupal::service('entity.repository')->loadEntityByUuid('block_content', $bid);

    $block->field_name = $new_value;
    
    $block->save();
  }

}

ฟังก์ชัน custom_module_batch_finished($success, $results, $operations)
{

  $messenger = \Drupal::messenger();
  ถ้า ($ สำเร็จ) {
    // ที่นี่เราสามารถทำสิ่งที่มีความหมายกับผลลัพธ์ได้
    // เราเพียงแค่แสดงจำนวนโหนดที่เราประมวลผล...

    ถ้า ($ ทั้งหมด) {
      $messenger->addMessage(t('@count ผลลัพธ์ที่ประมวลผลแล้ว', ['@count' => $total]));
    } อื่น {
      $messenger->addMessage(t('ไม่มีรายการสำหรับการย้ายข้อมูล'));
    }

  } อื่น {
    // เกิดข้อผิดพลาด.
    // $operations ประกอบด้วยการดำเนินการที่ยังไม่ผ่านการประมวลผล
    $error_operation = รีเซ็ต ($ การดำเนินการ);
    $messenger->addMessage(
      เสื้อ(
        'เกิดข้อผิดพลาดขณะประมวลผล @operation พร้อมอาร์กิวเมนต์: @args'
        [
          '@operation' => $error_operation[0],
          '@args' => print_r($error_operation[0], จริง),
        ]
      )
    );
  }
}

การดำเนินการแบบแบตช์จะใช้เมื่อไม่ทราบจำนวนรายการที่ต้องจัดการ และอาจมีรายการจำนวนมากที่การโหลดทั้งหมดจะใช้หน่วยความจำ PHP ที่มีอยู่ทั้งหมด หรือการจัดการจะใช้เวลามากกว่าเวลาที่ PHP ให้กับ สคริปต์ที่จะเรียกใช้ เมื่อข้อมูลถูกโหลดจากตารางฐานข้อมูล แม้แต่ข้อมูลเอนทิตี การเรียกกลับของการดำเนินการแบบแบตช์จะโหลดข้อมูล เช่น รหัสนี้ทำ เป็นต้น

$batch_builder = (BatchBuilder ใหม่ ())
  ->setTitle(t('การลบแถวฐานข้อมูล'))
  ->setFinishCallback('mymodule_finished_callback')
  ->addOperation('mymodule_delete_rows', []);

batch_set($batch_builder->toArray());

ฟังก์ชัน mymodule_delete_rows (&$ บริบท) {
  $connection = \Drupal::database();

  ถ้า (ว่าง ($ บริบท ['แซนด์บ็อกซ์'])) {
    $context['sandbox']['ความคืบหน้า'] = 0;
    $context['sandbox']['current_id'] = 0;
    $context['sandbox']['max'] = $connection
      ->query('เลือกนับ(DISTINCT [id]) จาก {example}')
      ->fetchField();
    $บริบท['ผลลัพธ์'] = 0;
  }

  $จำกัด = 5;
  $result = $การเชื่อมต่อ
    ->เลือก('ตัวอย่าง')
    ->condition('id', $context['sandbox']['current_id'], '>')
    ->orderBy('รหัส')
    ->ช่วง(0, $จำกัด)
    ->ดำเนินการ ();

  foreach (ผลลัพธ์ $ เป็น $ แถว) {
    $context['sandbox']['ความคืบหน้า']++;
    $บริบท['ผลลัพธ์']++;
    $context['sandbox']['current_id'] = $row->id;
    
    ถ้า (!empty($row->title) && is_numeric($row->title[0])) {
      $connection->delete('ตัวอย่าง')
        ->condition('id', $row->id)
        ->ดำเนินการ ()
    }
  }
  ถ้า ($context['sandbox']['progress'] != $context['sandbox']['max']) {
    $context['finished'] = $context['sandbox']['progress'] / $context['sandbox']['max'];
  }
}

ฟังก์ชัน mymodule_finished_callback ($ สำเร็จ, $ ผลลัพธ์, $ การดำเนินการ, $ ผ่านไป) {
  ถ้า ($ สำเร็จ) {
    $message = \Drupal::translation()->formatPlural($results, '@count แถวที่ถูกลบ', '@count แถวที่ถูกลบ');
  }
  อื่น {
    $message = t('เสร็จสิ้นโดยมีข้อผิดพลาด');
  }
  \Drupal::messenger()->addMessage($message);
}

ค่าที่เกี่ยวข้องที่ตั้งค่าในการเรียกกลับของการดำเนินการแบทช์คือค่าต่อไปนี้:

• $context['เสร็จสิ้น'] บอกให้ Drupal หยุดเรียกการเรียกกลับการดำเนินการแบบแบตช์ เมื่อค่าของมันคือ 1 หรือ $context['เสร็จสิ้น'] ไม่ได้ตั้งค่า
• $บริบท['ผลลัพธ์'] จะถูกส่งผ่านไปยังการเรียกกลับที่เรียกใช้เมื่อการดำเนินการแบทช์เสร็จสิ้น เป็นพารามิเตอร์ที่สอง
• $บริบท['ข้อความ'] เป็นข้อความที่แสดงในหน้าความคืบหน้า

ฉันจะไม่สร้างอาร์เรย์ที่มีค่าสำหรับแต่ละรายการที่จัดการ เนื่องจากจะใช้หน่วยความจำที่มีอยู่ทั้งหมด เมื่อรายการที่จัดการมีมาก

อ้างอิง

• การดำเนินการเป็นชุด
• callback_batch_operation()
• callback_batch_finished()
• ตัวสร้างแบทช์