bullmq

(★ 9,310)

BullMQ - Message Queue and Batch processing for NodeJS, Python, .NET, Elixir, Rust and PHP based on Redis or PostgreSQL

파일 탐색기

최종 버전 다운로드 (.zip)

- - bug.yaml
  - feature_request.md
- - codeql-analysis.yml
  - codeql.yml
  - docs.yml
  - dotnet-test.yml
  - elixir-test.yml
  - osv-scanner-scheduled.yml
  - osv-scanner.yml
  - python-test.yml
  - release.yml
  - rust-test.yml
  - test.yml
  - valkey-glide-test.yml
- pull_request_template.md
- commit-msg
- pre-commit
- api-extractor.json
- - config.mts
  - gitbook.ts
  - sidebar.ts
- - changelog.md
  - quick-start.md
  - README.md
  - SUMMARY.md
- - test.sh
- .gitignore
- BullMQ.slnx
- package.json
- README.md
- - add_job_benchmark.exs
  - redis_baseline.exs
  - suite.exs
  - throughput_benchmark.exs
- - config.exs
  - test.exs
- - transactional-jobs-design.md
- - benchmarks.md
  - deduplication.md
  - flows.md
  - getting_started.md
  - introduction.md
  - job_cancellation.md
  - job_options.md
  - job_schedulers.md
  - manual_processing.md
  - queue_events.md
  - rate_limiting.md
  - scaling.md
  - telemetry.md
  - workers.md
- - bullmq.ex
- - updateVersion.js
- - test_helper.exs
- .credo.exs
- .formatter.exs
- .gitignore
- CHANGELOG.md
- LICENSE
- mix.exs
- mix.lock
- package.json
- README.md
- yarn.lock
- - updateVersion.js
- - Job.php
  - JobOptions.php
  - Queue.php
  - QueueKeys.php
  - RedisConnection.php
  - Scripts.php
- - JobOptionsTest.php
  - JobTest.php
  - QueueTest.php
- .gitignore
- composer.json
- LICENSE
- package.json
- phpstan.neon
- phpunit.xml
- README.md
- yarn.lock
- - __init__.py
  - abort_controller.py
  - backend.py
  - backoffs.py
  - error_code.py
  - event_emitter.py
  - flow_producer.py
  - job.py
  - job_scheduler.py
  - lock_manager.py
  - queue.py
  - queue_events.py
  - queue_events_producer.py
  - queue_keys.py
  - redis_connection.py
  - scripts.py
  - timer.py
  - utils.py
  - worker.py
- - __init__.py
  - bulk_test.py
  - conftest.py
  - deduplication_test.py
  - delay_test.py
  - flow_producer_test.py
  - flow_test.py
  - global_rate_limit_concurrency_test.py
  - job_cancellation_test.py
  - job_scheduler_test.py
  - job_test.py
  - lock_manager_test.py
  - postgres_backend_test.py
  - priority_test.py
  - queue_events_test.py
  - queue_getters_cluster_test.py
  - queue_job_types_test.py
  - queue_test.py
  - redis_connection_cluster_test.py
  - redis_connection_test.py
  - sql_loader_test.py
  - test_imports.py
  - worker_disconnect_test.py
  - worker_test.py
- .gitignore
- benchmark_backends.py
- CHANGELOG.md
- copy_scripts.sh
- flush_redis.py
- package.json
- pyproject.toml
- pytest.ini
- README.md
- release.sh
- run_tests.sh
- run_tests_dragonfly.sh
- run_tests_postgres.sh
- setup.py
- yarn.lock
- - benchmark.rs
- - error.rs
  - flow_producer.rs
  - job.rs
  - job_scheduler.rs
  - keys.rs
  - lib.rs
  - options.rs
  - queue.rs
  - queue_events.rs
  - redis_connection.rs
  - scripts.rs
  - types.rs
  - worker.rs
- - connection_test.rs
  - convenience_methods_test.rs
  - deduplication_test.rs
  - delay_test.rs
  - flow_test.rs
  - global_concurrency_test.rs
  - job_options_test.rs
  - job_scheduler_test.rs
  - job_test.rs
  - meta_test.rs
  - metrics_test.rs
  - prometheus_test.rs
  - queue_events_test.rs
  - queue_test.rs
  - rate_limit_test.rs
  - stalled_jobs_test.rs
  - worker_options_test.rs
  - worker_test.rs
  - workers_test.rs
- .gitignore
- Cargo.lock
- Cargo.toml
- FEATURE_PARITY.md
- package.json
- README.md
- yarn.lock
- commandTransform.js
- generateRawScripts.ts
- updateVersion.js
- - abort-controller.ts
  - async-fifo-queue.ts
  - backoffs.ts
  - bun-redis-client.ts
  - child-pool.ts
  - child-processor.ts
  - child.ts
  - finished-errors.ts
  - flow-producer.ts
  - index.ts
  - ioredis-client.ts
  - job-scheduler.ts
  - job.ts
  - lock-manager.ts
  - main-base.ts
  - main-worker.ts
  - main.ts
  - node-redis-client.ts
  - queue-base.ts
  - queue-events-producer.ts
  - queue-events.ts
  - queue-getters.ts
  - queue-keys.ts
  - queue.ts
  - redis-connection.ts
  - redis-queue-backend.ts
  - sandbox.ts
  - valkey-glide-client.ts
  - worker.ts
- - addDelayedJob-6.lua
  - addJobScheduler-11.lua
  - addLog-2.lua
  - addParentJob-6.lua
  - addPrioritizedJob-9.lua
  - addStandardJob-9.lua
  - changeDelay-4.lua
  - changePriority-7.lua
  - cleanJobsInSet-3.lua
  - drain-5.lua
  - extendLock-2.lua
  - extendLocks-1.lua
  - getCounts-1.lua
  - getCountsPerPriority-2.lua
  - getDependencyCounts-4.lua
  - getJobs-1.lua
  - getJobScheduler-1.lua
  - getMetrics-2.lua
  - getRanges-1.lua
  - getRateLimitTtl-2.lua
  - getState-8.lua
  - getStateV2-8.lua
  - index.ts
  - isFinished-3.lua
  - isJobInList-1.lua
  - isMaxed-2.lua
  - moveJobFromActiveToWait-9.lua
  - moveJobsToWait-8.lua
  - moveStalledJobsToWait-9.lua
  - moveToActive-11.lua
  - moveToDelayed-12.lua
  - moveToFinished-14.lua
  - moveToWaitingChildren-7.lua
  - obliterate-2.lua
  - paginate-1.lua
  - pause-7.lua
  - promote-9.lua
  - releaseLock-1.lua
  - removeChildDependency-1.lua
  - removeDeduplicationKey-1.lua
  - removeJob-2.lua
  - removeJobScheduler-3.lua
  - removeOrphanedJobs-1.lua
  - removeUnprocessedChildren-2.lua
  - reprocessJob-8.lua
  - retryJob-11.lua
  - saveStacktrace-1.lua
  - script-loader.ts
  - updateData-1.lua
  - updateJobScheduler-12.lua
  - updateProgress-3.lua
- - child-command.ts
  - error-code.ts
  - index.ts
  - metrics-time.ts
  - parent-command.ts
  - telemetry-attributes.ts
- - advanced-options.ts
  - backoff-options.ts
  - base-job-options.ts
  - child-message.ts
  - connection.ts
  - flow-job.ts
  - index.ts
  - ioredis-events.ts
  - job-json.ts
  - job-scheduler-json.ts
  - lock-manager-worker-context.ts
  - metrics-options.ts
  - metrics.ts
  - minimal-job.ts
  - minimal-queue.ts
  - parent-message.ts
  - parent-options.ts
  - parent.ts
  - queue-backend.ts
  - queue-meta.ts
  - queue-options.ts
  - rate-limiter-options.ts
  - receiver.ts
  - redis-client.ts
  - redis-options.ts
  - redis-streams.ts
  - repeat-options.ts
  - repeatable-options.ts
  - retry-options.ts
  - sandboxed-job-processor.ts
  - sandboxed-job.ts
  - sandboxed-options.ts
  - script-queue-context.ts
  - telemetry.ts
  - worker-options.ts
- - create-postgres-backend.ts
  - index.ts
  - migrator.ts
  - pg-types.ts
  - postgres-connection.ts
  - postgres-queue-backend.ts
  - sql-loader.ts
- - backoff-strategy.ts
  - database-type.ts
  - deduplication-options.ts
  - finished-status.ts
  - index.ts
  - job-json-sandbox.ts
  - job-options.ts
  - job-progress.ts
  - job-scheduler-template-options.ts
  - job-type.ts
  - keep-jobs.ts
  - processor.ts
  - repeat-strategy.ts
- - create-backend.ts
  - index.ts
- index.ts
- version.ts
- - delay.js
  - fixture_main_non_bullmq_messages.js
  - fixture_processor.cjs
  - fixture_processor.js
  - fixture_processor.mjs
  - fixture_processor_bar.js
  - fixture_processor_broken.js
  - fixture_processor_cancel.js
  - fixture_processor_crash.js
  - fixture_processor_env.js
  - fixture_processor_esbuild.js
  - fixture_processor_exit.js
  - fixture_processor_fail.js
  - fixture_processor_fail_init_once.js
  - fixture_processor_fail_with_circular_reference.js
  - fixture_processor_foo.js
  - fixture_processor_get_children_failures.js
  - fixture_processor_get_children_failures_child.js
  - fixture_processor_get_children_values.js
  - fixture_processor_get_children_values_child.js
  - fixture_processor_get_dependencies.js
  - fixture_processor_get_dependencies_child.js
  - fixture_processor_get_dependencies_count.js
  - fixture_processor_get_dependencies_count_child.js
  - fixture_processor_missing_function.js
  - fixture_processor_move_to_delayed.js
  - fixture_processor_move_to_wait.js
  - fixture_processor_move_to_wait_for_children.js
  - fixture_processor_parent.js
  - fixture_processor_queueName.js
  - fixture_processor_simple.js
  - fixture_processor_slow.js
  - fixture_processor_stderr.js
  - fixture_processor_stdout.js
  - fixture_processor_steps.js
  - fixture_processor_ttl.js
  - fixture_processor_unrecoverable.js
  - fixture_processor_update_data.js
  - fixture_processor_update_progress.js
  - fixture_processor_with_extra_param.js
- - migration.test.ts
  - operations.test.ts
  - sql_loader.test.ts
  - worker.test.ts
- - cleanup-queue.ts
  - connection-factory.ts
  - get-redis-client.ts
  - lodash.ts
  - repeat_utils.ts
  - stream-events.ts
- adapter-conformance.test.ts
- async_fifo_queue.test.ts
- bulk.test.ts
- bun-adapter-suite.test.ts
- bun-redis.test.ts
- child-pool.test.ts
- child_stdio_null.test.ts
- clean.redis.test.ts
- clean.test.ts
- cluster.test.ts
- concurrency.test.ts
- connection-closed-error.test.ts
- connection.test.ts
- deduplication.test.ts
- delay.redis.test.ts
- delay.test.ts
- events.redis.test.ts
- events.test.ts
- flow.redis.test.ts
- flow.test.ts
- getters.redis.test.ts
- getters.test.ts
- integration_dedicated_lock_thread.ts
- ioredis-client.test.ts
- job.redis.test.ts
- job.test.ts
- job_cancellation.test.ts
- job_cancellation_advanced.test.ts
- job_scheduler.redis.test.ts
- job_scheduler.test.ts
- job_scheduler_stress.test.ts
- lock_manager.test.ts
- metrics.test.ts
- node-redis.test.ts
- obliterate.redis.test.ts
- obliterate.test.ts
- pause.test.ts
- postgres-queue-backend.test.ts
- queue.redis.test.ts
- queue.test.ts
- rate_limiter.test.ts
- sandboxed_process.test.ts
- script_loader.test.ts
- scripts.test.ts
- stalled_jobs.test.ts
- telemetry_interface.test.ts
- valkey-glide-client.test.ts
- worker.redis.test.ts
- worker.test.ts
.gitignore
.madgerc
.mocharc.js
.npmignore
.nvmrc
.prettierignore
.prettierrc.js
CHANGELOG.md
CODE_OF_CONDUCT.md
commitlint.config.js
composer.json
contributing.md
docker-compose.yml
eslint.config.mjs
LICENSE
mocha.setup.ts
osv-scanner.toml
package.json
README.md
renovate.json
tsconfig-cjs.json
tsconfig.json
tsconfig.tests-check.json
tsdoc.json
vitest.adapter-conformance.config.ts
vitest.bun.config.ts
vitest.bun.setup.ts
vitest.config.ts
vitest.coverage.config.ts
vitest.ioredis.config.ts
vitest.node-redis.config.ts
vitest.node-redis.setup.ts
vitest.postgres.config.ts
vitest.postgres.global-setup.ts
vitest.postgres.setup.ts
vitest.postgres.smoke.config.ts
vitest.setup.ts
vitest.valkey-glide.config.ts
vitest.valkey-glide.setup.ts
yarn.lock

# 설치 가이드

1. 코드 내려받기

git clone https://github.com/taskforcesh/bullmq

깃허브에서 프로젝트 코드 전체를 내 컴퓨터로 내려받습니다.

cd bullmq

방금 내려받은 프로젝트 폴더 안으로 이동합니다.

2. Docker

쉬움 추천

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Docker Desktop 컨테이너를 빌드하고 실행하려면 필요합니다. 설치 후 실행해서 백그라운드에 켜두세요.

docker compose up -d --build

정의된 모든 컨테이너(서버, DB 등)를 한 번에 빌드하고 백그라운드에서 실행합니다.

✅ 터미널에 docker compose ps 를 입력해 컨테이너들이 Up 상태인지 확인하세요. README에 포트 번호가 적혀있다면 브라우저에서 http://localhost:포트번호 로 접속해보세요.

3. .NET

보통

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
.NET SDK dotnet 명령어를 쓰기 위한 SDK입니다.

⚠️ 이 프로젝트는 규모가 큰 저장소라, 이 방법이 실제 핵심 제품이 아니라 내부 하위 패키지를 가리키는 것일 수 있습니다. README 전체를 함께 확인해보세요.

cd dotnet/src/BullMQ

이 프로젝트의 관련 파일이 하위 폴더 안에 있어서, 먼저 그 폴더로 이동합니다.

dotnet restore

프로젝트에 필요한 패키지를 내려받습니다.

dotnet run

프로젝트를 빌드하고 바로 실행합니다.

✅ dotnet run 실행 후 터미널에 나타나는 안내 메시지나 주소를 확인하세요.

4. Node.js

쉬움

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Node.js npm 명령어를 쓰려면 Node.js가 설치되어 있어야 합니다. LTS(장기지원) 버전을 추천합니다.

$ yarn add bullmq

이 명령어를 터미널에 그대로 입력해 실행하세요.

✅ 명령어 실행 후 터미널에 나타나는 주소(보통 http://localhost:3000 형태)를 브라우저에서 열어보세요.

이 레포의 README에 적힌 실제 명령어를 그대로 가져왔습니다.

5. Python

쉬움

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Python 3 설치 시 'Add Python to PATH' 옵션을 꼭 체크하세요 (Windows).

pip install .

PyPI에 배포된 패키지를 바로 설치합니다. 소스 클론이 필요 없습니다.

python <실행할 파일명>.py # README에서 정확한 실행 파일명을 확인하세요

파이썬 스크립트(또는 모듈)를 실행합니다.

✅ 에러 메시지 없이 실행되고 터미널에 안내 문구가 출력되면 정상입니다.

6. PHP (Composer)

쉬움

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
PHP PHP 실행 환경이 필요합니다.
Composer PHP 라이브러리 설치를 위한 패키지 매니저입니다.

composer install

composer.json에 명시된 PHP 라이브러리를 설치합니다.

✅ php -S localhost:8000 같은 내장 서버로 실행한 뒤 브라우저에서 http://localhost:8000 으로 접속해보세요.

7. Rust

보통

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Rust (rustup) rustup으로 설치하면 cargo도 함께 설치됩니다.

cd rust

이 프로젝트의 관련 파일이 하위 폴더 안에 있어서, 먼저 그 폴더로 이동합니다.

cargo build --release

Rust 프로젝트를 컴파일합니다.

cargo run

빌드 후 바로 실행까지 진행합니다.

✅ cargo build가 에러 없이 끝나면 성공입니다. target/ 폴더에 실행 파일이 생성됩니다.

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

bullmq

파일 탐색기

# 설치 가이드

2. Docker

3. .NET

4. Node.js

5. Python

6. PHP (Composer)

7. Rust

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

bullmq

파일 탐색기

# 설치 가이드

2. Docker

3. .NET

4. Node.js

5. Python

6. PHP (Composer)

7. Rust

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README