[NATS RPC] Tạo batch Task mới

POST

/nats/task/request/create

NATS Subject: task.request.create
Pattern: Request-Reply (RPC)
Queue Group: social-tool-group

Nhận batch task từ API Server, kiểm tra capacity, lưu vào MongoDB và bắt đầu xử lý qua Cron.

Payload hỗ trợ nhiều format:

{tasks: [...]} — Mảng task trực tiếp

{data: {payload: "{\"tasks\":[...]}"}} — Từ processItemRequest()

{payload: "{\"tasks\":[...]}"} — String JSON lồng

[...] — Mảng trực tiếp

Back-pressure: Nếu tổng pending > MAX_TOTAL_PENDING_TASKS, batch bị reject.
Trigger reallocation: Nếu batch ≥ 10 tasks, tự động trigger tái phân bổ worker.

Request

Body Params application/jsonRequired

Examples

Responses

🟢200

application/json

✅ Accepted — Tool chấp nhận batch

Body

🟠429

🔴500

Request Example

Shell

JavaScript

Java

Swift

curl --location --request POST '/nats/task/request/create' \
--header 'Content-Type: application/json' \
--data-raw '{
    "tasks": [
        {
            "task_id": 0,
            "group_id": "string",
            "created_by": 0,
            "campaign_platform_id": 0,
            "social_account_id": 0,
            "action_name": "string",
            "page": {
                "page_url": "string",
                "title": "string",
                "type": "string"
            },
            "action": {
                "id": "string",
                "name": "string",
                "description": "string"
            },
            "comment": "string",
            "content": {
                "mode": "string",
                "reaction": {
                    "reaction_ids": [
                        0
                    ]
                }
            },
            "reaction_type": "string",
            "post_settings": {
                "destination": "string",
                "audience": "string",
                "context": "string",
                "media": [
                    {
                        "url": "string",
                        "type": "string"
                    }
                ]
            },
            "social_account": {
                "id": 0,
                "name": "string",
                "status": "string",
                "active": true,
                "user_agent": "string",
                "device_size": {
                    "width": 0,
                    "height": 0,
                    "ratio": 0
                },
                "value": "string",
                "username": "string",
                "password": "string",
                "secret_key": "string",
                "newFirstName": "string",
                "newMiddleName": "string",
                "newLastName": "string",
                "newAvatarUrl": "string"
            },
            "proxy": {
                "id": 0,
                "ip": "string",
                "port": 0,
                "username": "string",
                "password": "string",
                "rotate_url": "string"
            },
            "keywords": "string",
            "contents": {
                "urls": [
                    "string"
                ],
                "other_info": "string",
                "search_term": "string",
                "report_detail": [
                    {
                        "name": "string",
                        "position": 0
                    }
                ],
                "report_category": {
                    "id": 0,
                    "name": "string",
                    "description": "string"
                }
            },
            "social": {
                "id": 0,
                "slug": "string"
            },
            "skipPost": 0,
            "targetGroup": "string",
            "avatarUrl": "string",
            "post": {
                "post_image_urls": [
                    "string"
                ],
                "comment_image_url": "string"
            },
            "comment_info": {
                "ai_info": {
                    "api_key": "string",
                    "instruction": "string",
                    "prompt": "string",
                    "generated": "string",
                    "generated_list": "string"
                },
                "text": "string",
                "comment_image_url": "string",
                "keyword": "string"
            },
            "share_info": {
                "ai_info": {
                    "api_key": "string",
                    "instruction": "string",
                    "prompt": "string",
                    "generated": "string",
                    "generated_list": "string"
                },
                "text": "string",
                "from_url": "string",
                "to_url": "string"
            },
            "reply_info": {
                "ai_info": {
                    "api_key": "string",
                    "instruction": "string",
                    "prompt": "string",
                    "generated": "string",
                    "generated_list": "string"
                },
                "text": "string",
                "number_reply": 1
            },
            "captcha_info": {
                "api_key": "string",
                "service_name": "string"
            },
            "page_info": {
                "id": "string",
                "page_url": "string",
                "type": "string",
                "description": "string"
            }
        }
    ]
}'

Response Example

200 - Example 1

{
    "status": "accepted",
    "message": "Accepted batch of 5 tasks",
    "tasksAccepted": 5,
    "currentPending": 15,
    "maxPending": 30
}

Modified at 2026-03-28 05:49:45

Product

[NATS RPC] Lấy danh sách tất cả Tasks