| 12345678910111213141516171819202122232425262728293031323334353637383940414243 |
- create table sj_retry
- (
- id bigint unsigned auto_increment comment '主键'
- primary key,
- namespace_id varchar(64) default '764d604ec6fc45f68cd92514c40e9e1a' not null comment '命名空间id',
- group_name varchar(64) not null comment '组名称',
- group_id bigint not null comment '组Id',
- scene_name varchar(64) not null comment '场景名称',
- scene_id bigint not null comment '场景ID',
- idempotent_id varchar(64) not null comment '幂等id',
- biz_no varchar(64) default '' not null comment '业务编号',
- executor_name varchar(512) default '' not null comment '执行器名称',
- args_str text not null comment '执行方法参数',
- ext_attrs text not null comment '扩展字段',
- next_trigger_at bigint not null comment '下次触发时间',
- retry_count int default 0 not null comment '重试次数',
- retry_status tinyint default 0 not null comment '重试状态 0、重试中 1、成功 2、最大重试次数',
- task_type tinyint default 1 not null comment '任务类型 1、重试数据 2、回调数据',
- bucket_index int default 0 not null comment 'bucket',
- parent_id bigint default 0 not null comment '父节点id',
- deleted bigint default 0 not null comment '逻辑删除',
- create_dt datetime default CURRENT_TIMESTAMP not null comment '创建时间',
- update_dt datetime default CURRENT_TIMESTAMP not null on update CURRENT_TIMESTAMP comment '修改时间',
- constraint uk_scene_tasktype_idempotentid_deleted
- unique (scene_id, task_type, idempotent_id, deleted)
- )
- comment '重试信息表';
- create index idx_biz_no
- on sj_retry (biz_no);
- create index idx_create_dt
- on sj_retry (create_dt);
- create index idx_idempotent_id
- on sj_retry (idempotent_id);
- create index idx_parent_id
- on sj_retry (parent_id);
- create index idx_retry_status_bucket_index
- on sj_retry (retry_status, bucket_index);
|
