正在显示
1 个修改的文件
包含
7 行增加
和
3 行删除
| @@ -37,6 +37,7 @@ class SyncToEsCmd { | @@ -37,6 +37,7 @@ class SyncToEsCmd { | ||
| 37 | while ($maxNum > 0){ | 37 | while ($maxNum > 0){ |
| 38 | // 验证最大执行时间 | 38 | // 验证最大执行时间 |
| 39 | if(time() - $runTime > $maxTime){ | 39 | if(time() - $runTime > $maxTime){ |
| 40 | + _echo('超过进程最大执行时间'); | ||
| 40 | break; | 41 | break; |
| 41 | } | 42 | } |
| 42 | 43 | ||
| @@ -60,18 +61,21 @@ class SyncToEsCmd { | @@ -60,18 +61,21 @@ class SyncToEsCmd { | ||
| 60 | 61 | ||
| 61 | $code = $es->save($doc_id,$data); | 62 | $code = $es->save($doc_id,$data); |
| 62 | if($code!==200){ | 63 | if($code!==200){ |
| 64 | + _echo('同步es: '.$doc_id.'===>'.$code); | ||
| 63 | sleep(1); | 65 | sleep(1); |
| 64 | $code = $es->save($doc_id,$data); // 重试一次 | 66 | $code = $es->save($doc_id,$data); // 重试一次 |
| 65 | } | 67 | } |
| 66 | - | ||
| 67 | - _echo('同步es: '.$doc_id.'===>'.$code); | 68 | + if($code!==200){ |
| 69 | + _echo('同步es: '.$doc_id.'===>'.$code); | ||
| 70 | + } | ||
| 68 | continue; | 71 | continue; |
| 69 | } | 72 | } |
| 70 | } | 73 | } |
| 71 | 74 | ||
| 72 | - echo '没有找到数据'.PHP_EOL; | 75 | + _echo('没有找到数据'); |
| 73 | 76 | ||
| 74 | if(time() - $runTime > $minTime){ | 77 | if(time() - $runTime > $minTime){ |
| 78 | + _echo('最小执行时间 退出'); | ||
| 75 | break; | 79 | break; |
| 76 | } | 80 | } |
| 77 | 81 |
-
请 注册 或 登录 后发表评论