fix: 增加ref对应的blob数量超过限制日志输出 #2181

TencentBlueKing · Nov 15, 2024 · fc6a73f · fc6a73f
1 parent 0ca5b97
commit fc6a73f
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/...ackend/ddc/biz-ddc/src/main/kotlin/com/tencent/bkrepo/ddc/repository/BlobRefRepository.kt b/...ackend/ddc/biz-ddc/src/main/kotlin/com/tencent/bkrepo/ddc/repository/BlobRefRepository.kt
@@ -12,6 +12,10 @@ import org.springframework.stereotype.Repository
 @Repository
 class BlobRefRepository : SimpleMongoDao<TDdcBlobRef>() {
     fun addRefToBlob(projectId: String, repoName: String, bucket: String, refKey: String, blobIds: Set<String>) {
+        if (blobIds.size > DEFAULT_BLOB_SIZE_LIMIT) {
+            val ref = "$projectId/$repoName/${buildRef(bucket, refKey)}"
+            logger.error("blobs of ref[$ref] exceed size limit, size[${blobIds.size}]]")
+        }
         blobIds.forEach {
             try {
                 insert(
@@ -35,4 +39,8 @@ class BlobRefRepository : SimpleMongoDao<TDdcBlobRef>() {
             .and(TDdcBlobRef::ref.name).isEqualTo(buildRef(bucket, refKey))
         return determineMongoTemplate().findAllAndRemove(Query(criteria), TDdcBlobRef::class.java)
     }
+
+    companion object {
+        private const val DEFAULT_BLOB_SIZE_LIMIT = 20
+    }
 }