使用 kubernetes 作业运行 mongo shell 脚本

Question

我需要创建将在 mongo shell 上运行以下脚本的 kubernetes 作业：

var operations = [];
db.product.find().forEach(function(doc) {
    var documentLink = doc.documentLink; 
    var operation = { updateMany :{ 
"filter" : {"_id" : doc._id},
"update" : {$set:{"documentLinkMap.en":documentLink,"documentLinkMap.de":""},
    $unset: {documentLink:"","descriptionMap.tr":"","news.tr":"","descriptionInternal.tr":"","salesDescription.tr":"","salesInternal.tr":"","deliveryDescription.tr":"","deliveryInternal.tr":"","productRoadMapDescription.tr":"","productRoadMapInternal.tr":"","technicalsAndIntegration.tr":"","technicalsAndIntegrationInternal.tr":"","versions.$[].descriptionMap.tr":"","versions.$[].releaseNoteMap.tr":"","versions.$[].artifacts.$[].descriptionMap.tr":"","versions.$[].artifacts.$[].artifactNotes.tr":""}}}};
    operations.push(operation); 
});
operations.push( {
    ordered: true,      
    writeConcern: { w: "majority", wtimeout: 5000 } 
});
db.product.bulkWrite(operations);

我需要该作业的示例。我应该创建持久卷并声明其所有权，还是可以在没有持久卷的情况下运行此作业？我需要运行一次然后将其删除。

Answer 1

您可以使用 configMap，然后将 configMap 安装为将在文件中解析的卷。

下面是如何继续操作的示例（注意！您需要为其使用正确的图像以及 mongo shell 工作方式的一些其他更改）：

1. 从文件创建一个 configMap。可以通过运行以下命令来完成：

   $ kubectl create cm mongoscript-cm --from-file=mongoscript.js
   已创建 configmap/mongoscript-cm
   

   您可以通过运行以下命令来检查您的文件是否存储在其中：

   $ kubectl 描述 cm mongoscript-cm
   

2. 从 configmap 创建一个带有卷挂载的作业 (规范模板与 pod 中使用的相同）：

   api版本：batch/v1
   种类：工作
   元数据：
     名称： mongojob
   规格：
     模板：
       规格：
         容器：
         - 名称：mongojob
           image: ubuntu # 出于测试目的，您需要使用合适的
           命令：['bin/bash', '-c', 'echo STARTED ;猫 /opt/mongoscript.js ;睡眠 120 ； echo FINISHED'] # 命令相同，用于演示目的
           体积安装：
           - 名称：mongoscript
             mountPath: /opt # 文件挂载位置
         卷：
         - 名称：mongoscript
           配置映射：
             name: mongoscript-cm # 引用之前创建的configmap
         restartPolicy: OnFailure # 作业所需
   

3. 检查它在 Pod 内部的外观

   连接到 Pod：

   $ kubectl exec -it mongojob--1-8w4ml -- /bin/bash
   

   检查文件已显示：

   <前><代码># ls /opt
   mongoscript.js

   检查其内容：

   # cat /opt/mongoscript.js 
   var 操作 = [];
   db.product.find().forEach(函数(doc) {
       var documentLink = doc.documentLink; 
       var 操作 = { updateMany :{ 
   “过滤器”：{“_id”：doc._id}，
   “更新”：{$set {“documentLinkMap.en”：documentLink，“documentLinkMap.de”：“”}，
       $未设置： {documentLink:"","descriptionMap.tr":"","news.tr":"","descriptionInternal.tr":"","salesDescription.tr":"","salesInternal.tr ":"","deliveryDescription.tr":"","deliveryInternal.tr":"","productRoadMapDescription.tr":"","productRoadMapInternal.tr":""," TechnicalsAndIntegration.tr":"","technicalsAndIntegrationInternal.tr":"","版本.$[].descriptionMap.tr":"","版本.$[].r eleaseNoteMap.tr":"","versions.$[].artifacts.$[].descriptionMap.tr":"","versions.$[].artifacts.$[].artifactNotes.tr":""} }}}；
       操作.push(操作); 
   });
   操作.push( {
       订购：真实，      
       writeConcern: { w: "多数", wtimeout: 5000 } 
   });
   db.product.bulkWrite(操作);