Saya baru mengenal broker pesan seperti RabbitMQ yang dapat kita gunakan untuk membuat tugas / antrian pesan untuk sistem penjadwalan seperti Celery . Sekarang, inilah pertanyaannya: Saya dapat membuat tabel di PostgreSQL yang dapat ditambahkan dengan tugas-tugas baru dan dikonsumsi oleh program...
Bagaimana saya bisa menghapus semua tugas yang tertunda tanpa mengetahui task_iduntuk setiap
Bagaimana saya bisa mengambil daftar tugas dalam antrian yang belum
Dokumentasi Celery menyebutkan pengujian Celery dalam Django tetapi tidak menjelaskan bagaimana menguji tugas Celery jika Anda tidak menggunakan Django. Bagaimana kamu melakukan
Tertutup . Pertanyaan ini perlu lebih difokuskan . Saat ini tidak menerima jawaban. Ingin memperbaiki pertanyaan ini? Perbarui pertanyaan agar fokus pada satu masalah hanya dengan mengedit posting ini . Tutup 3 tahun lalu . Perbaiki pertanyaan ini...
Saya mencoba menjalankan contoh dari dokumentasi Celery. Saya berlari: celeryd --loglevel=INFO /usr/local/lib/python2.7/dist-packages/celery/loaders/default.py:64: NotConfigured: No 'celeryconfig' module found! Please make sure it exists and is available to Python. "is available to Python." %...
Saya telah membaca dokumen dan mencari tetapi tidak dapat menemukan jawaban langsung: Bisakah Anda membatalkan tugas yang sudah dijalankan? (seperti dalam tugas telah dimulai, membutuhkan beberapa saat, dan setengah jalan perlu dibatalkan) Saya menemukan ini dari dokumen di FAQ
Bagaimana cara memeriksa apakah tugas sedang berjalan dalam seledri (khususnya, saya menggunakan celery-django)? Saya telah membaca dokumentasinya, dan saya telah mencari di Google, tetapi saya tidak dapat melihat panggilan seperti: my_example_task.state() == RUNNING Kasus penggunaan saya...
Saya kesulitan memahami tujuan 'antrian tugas terdistribusi'. Misalnya, perpustakaan seledri python . Saya tahu bahwa di seledri, kerangka python, Anda dapat mengatur jendela berjangka waktu agar fungsi dapat dijalankan. Namun, itu juga dapat dengan mudah dilakukan di crontab linux yang...
Misalkan saya punya model Event. Saya ingin mengirim pemberitahuan (email, push, apa pun) ke semua pengguna yang diundang setelah acara berlalu. Sesuatu di sepanjang garis: class Event(models.Model): start = models.DateTimeField(...) end = models.DateTimeField(...) invited =