• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Python subprocess.process函数代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Python中subprocess.process函数的典型用法代码示例。如果您正苦于以下问题:Python process函数的具体用法?Python process怎么用?Python process使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。



在下文中一共展示了process函数的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: execute

def execute(*command, **kwargs):
    kwargs.update(universal_newlines=True)
    proc = process(command, **kwargs)
    _, _ = proc.communicate()
    code = proc.returncode
    if not code: return code
    sys.exit(code)
开发者ID:acmorrow,项目名称:core,代码行数:7,代码来源:utility.py


示例2: run

    def run(self):
        try:
            batch = process([configuration.executables.GIT, 'cat-file', '--batch'], stdin=PIPE, stdout=PIPE, stderr=STDOUT, cwd=self.repository.path)

            stdout, stderr = batch.communicate("\n".join(self.sha1s.keys()) + "\n")

            gitobjects = []

            for sha1, commit_id in self.sha1s.items():
                line, stdout = stdout.split("\n", 1)

                try: object_sha1, object_type, object_size = line.split(" ")
                except: raise Exception, "unexpected header line: %r" % line

                assert object_sha1 == sha1, "%s != %s (%s)" % (object_sha1, sha1)
                assert object_type == "commit"

                object_size = int(object_size)

                object_data = stdout[:object_size]
                stdout = stdout[object_size + 1:]

                gitobjects.append((GitObject(object_sha1, object_type, object_size, object_data), commit_id))

            self.gitobjects = gitobjects
        except:
            self.error = format_exc()
开发者ID:KurSh,项目名称:critic,代码行数:27,代码来源:gitutils.py


示例3: check_input

def check_input(args, stdin, **kwargs):
    assert isinstance(stdin, str)

    child = process(args, stdin=PIPE, **kwargs)
    stdout, stderr = child.communicate(stdin)

    if child.returncode != 0:
        raise CalledProcessError(child.returncode, args, None)
开发者ID:KurSh,项目名称:critic,代码行数:8,代码来源:process.py


示例4: lstree

    def lstree(remote, regexp=None):
        if regexp: name_check = lambda item: bool(regexp.match(item[1]))
        else: name_check = lambda item: True

        git = process([configuration.executables.GIT, 'ls-remote', remote], stdout=PIPE, stderr=PIPE, cwd="/tmp")
        stdout, stderr = git.communicate()

        if git.returncode == 0: return filter(name_check, (line.split() for line in stdout.splitlines()))
        else: raise Exception, "'git ls-remote' failed: %s" % stderr.strip()
开发者ID:KurSh,项目名称:critic,代码行数:9,代码来源:gitutils.py


示例5: lint

def lint(code, comment):
    # write input code to tmp file
    fp = temp_file.format(tmp=temp_dir)
    with open(fp, "w") as fh:
        fh.write(code)
        fh.close()

    # lint it
    out, err = process(["pep8", "--count", abspath(fp)],
                       stdout=PIPE,
                       stderr=STDOUT).communicate()

    if out == b'':
        comment("Good adherence to PEP8")
        return 1
    else:
        comment(out)
        return 1 - len(str(out).split("\n")) / len(code.split("\n"))
开发者ID:pombredanne,项目名称:integrity-1,代码行数:18,代码来源:formatting.py


示例6: mergebase

    def mergebase(self, commit_or_commits, db=None):
        if db and isinstance(commit_or_commits, Commit):
            cursor = db.cursor()
            cursor.execute("SELECT mergebase FROM mergebases WHERE commit=%s", (commit_or_commits.getId(db),))
            try:
                return cursor.fetchone()[0]
            except:
                result = self.mergebase(commit_or_commits)
                cursor.execute("INSERT INTO mergebases (commit, mergebase) VALUES (%s, %s)", (commit_or_commits.getId(db), result))
                return result

        try: sha1s = commit_or_commits.parents
        except: sha1s = map(str, commit_or_commits)

        assert len(sha1s) >= 2

        git = process([configuration.executables.GIT, 'merge-base'] + sha1s,
                      stdout=PIPE, stderr=PIPE, cwd=self.path)
        stdout, stderr = git.communicate()
        if git.returncode == 0: return stdout.strip()
        else: raise Exception, "'git merge-base' failed: %s" % stderr.strip()
开发者ID:KurSh,项目名称:critic,代码行数:21,代码来源:gitutils.py


示例7: runCustom

 def runCustom(self, cwd, command, *arguments, **kwargs):
     argv = [configuration.executables.GIT, command]
     argv.extend(arguments)
     stdin_data = kwargs.get("input")
     if stdin_data is None: stdin = None
     else: stdin = PIPE
     env = {}
     env.update(environ)
     env.update(kwargs.get("env", {}))
     if "GIT_DIR" in env: del env["GIT_DIR"]
     git = process(argv, stdin=stdin, stdout=PIPE, stderr=PIPE, cwd=cwd, env=env)
     stdout, stderr = git.communicate(stdin_data)
     if kwargs.get("check_errors", True):
         if git.returncode == 0:
             if kwargs.get("include_stderr", False):
                 return stdout + stderr
             else:
                 return stdout
         else: raise Exception, "'%s' failed: %s (in %s)" % (" ".join(argv), stderr.strip(), cwd)
     else:
         return git.returncode, stdout, stderr
开发者ID:KurSh,项目名称:critic,代码行数:21,代码来源:gitutils.py


示例8: readObject

 def readObject(repository_path, object_type, object_sha1):
     git = process([configuration.executables.GIT, 'cat-file', object_type, object_sha1], stdout=PIPE, stderr=PIPE, cwd=repository_path)
     stdout, stderr = git.communicate()
     if git.returncode == 0: return stdout
     else: raise Exception, "'git cat-file' failed: %s" % stderr.strip()
开发者ID:KurSh,项目名称:critic,代码行数:5,代码来源:gitutils.py


示例9: iscommit

 def iscommit(self, name):
     git = process([configuration.executables.GIT, 'cat-file', '-t', name],
                   stdout=PIPE, stderr=PIPE, cwd=self.path)
     stdout, stderr = git.communicate()
     if git.returncode == 0: return stdout.strip() == "commit"
     else: return False
开发者ID:KurSh,项目名称:critic,代码行数:6,代码来源:gitutils.py


示例10: revparse

 def revparse(self, name):
     git = process([configuration.executables.GIT, 'rev-parse', '--verify', '--quiet', name],
                   stdout=PIPE, stderr=PIPE, cwd=self.path)
     stdout, stderr = git.communicate()
     if git.returncode == 0: return stdout.strip()
     else: raise Exception, "'git rev-parse' failed: %s" % stderr.strip()
开发者ID:KurSh,项目名称:critic,代码行数:6,代码来源:gitutils.py


示例11: branch

 def branch(self, name, startpoint):
     git = process([configuration.executables.GIT, 'branch', name, startpoint],
                   stdout=PIPE, stderr=PIPE, cwd=self.path)
     stdout, stderr = git.communicate()
     if git.returncode != 0: raise Exception, stderr
开发者ID:KurSh,项目名称:critic,代码行数:5,代码来源:gitutils.py


示例12: __startBatchCheck

 def __startBatchCheck(self):
     if self.__batchCheck is None:
         self.__batchCheck = process([configuration.executables.GIT, 'cat-file', '--batch-check'],
                                     stdin=PIPE, stdout=PIPE, stderr=STDOUT, cwd=self.path)
开发者ID:KurSh,项目名称:critic,代码行数:4,代码来源:gitutils.py


示例13: __compact

        def __compact(self):
            import syntaxhighlight

            cache_dir = configuration.services.HIGHLIGHT["cache_dir"]

            if not os.path.isdir(cache_dir):
                # Newly installed system that hasn't highlighted anything.
                return 0, 0, 0, 0

            self.info("cache compacting started")

            now = time.time()

            max_age_uncompressed = 7 * 24 * 60 * 60
            max_age_compressed = 90 * 24 * 60 * 60

            uncompressed_count = 0
            compressed_count = 0

            purged_paths = []

            db = dbutils.Database.forSystem()

            cursor = db.cursor()

            cursor.execute("CREATE TEMPORARY TABLE purged (sha1 CHAR(40) PRIMARY KEY)")
            cursor.execute("INSERT INTO purged (sha1) SELECT DISTINCT sha1 FROM codecontexts")

            for section in sorted(os.listdir(cache_dir)):
                if len(section) == 2:
                    for filename in os.listdir("%s/%s" % (cache_dir, section)):
                        fullname = "%s/%s/%s" % (cache_dir, section, filename)
                        age = now - os.stat(fullname).st_mtime

                        parts = filename.split(".")

                        if len(parts) < 2 \
                                or len(parts[0]) != 38 \
                                or parts[1] not in syntaxhighlight.LANGUAGES:
                            os.unlink(fullname)
                            continue

                        sha1 = section + parts[0]

                        if parts[-1] == "bz2":
                            if age > max_age_compressed:
                                self.debug("purging: %s/%s" % (section, filename))
                                purged_paths.append(fullname)
                            else:
                                cursor.execute("DELETE FROM purged WHERE sha1=%s", (sha1,))
                                compressed_count += 1
                        elif parts[-1] == "ctx":
                            self.debug("deleting context file: %s/%s" % (section, filename))
                            os.unlink(fullname)
                        else:
                            cursor.execute("DELETE FROM purged WHERE sha1=%s", (sha1,))
                            if age > max_age_uncompressed:
                                self.debug("compressing: %s/%s" % (section, filename))
                                worker = process(["/bin/bzip2", fullname])
                                worker.wait()
                                compressed_count += 1
                            else:
                                uncompressed_count += 1

            self.info("cache compacting finished: uncompressed=%d / compressed=%d / purged=%d"
                      % (uncompressed_count, compressed_count, len(purged_paths)))

            if purged_paths:
                for path in purged_paths: os.unlink(path)

            cursor.execute("SELECT COUNT(*) FROM purged")

            purged_contexts = cursor.fetchone()[0]

            cursor.execute("""DELETE
                                FROM codecontexts
                               WHERE sha1 IN (SELECT sha1
                                                FROM purged)""")

            db.commit()
            db.close()

            return uncompressed_count, compressed_count, len(purged_paths), purged_contexts
开发者ID:jensl,项目名称:critic,代码行数:83,代码来源:highlight.py


示例14: __compact

        def __compact(self):
            import syntaxhighlight

            now = time.time()

            max_age_uncompressed = 7 * 24 * 60 * 60
            max_age_compressed = 90 * 24 * 60 * 60

            uncompressed_count = 0
            compressed_count = 0

            purged_paths = []

            db = dbutils.Database()
            cursor = db.cursor()

            cursor.execute("CREATE TEMPORARY TABLE purged (sha1 CHAR(40) PRIMARY KEY)")

            cache_path = configuration.services.HIGHLIGHT["cache_dir"]

            for section in sorted(os.listdir(cache_path)):
                if len(section) == 2:
                    for filename in os.listdir("%s/%s" % (cache_path, section)):
                        fullname = "%s/%s/%s" % (cache_path, section, filename)
                        age = now - os.stat(fullname).st_mtime

                        if len(filename) > 38 and filename[38] == "." and filename[39:] in syntaxhighlight.LANGUAGES:
                            if age > max_age_uncompressed:
                                self.debug("compressing: %s/%s" % (section, filename))
                                worker = process(["/bin/bzip2", fullname])
                                worker.wait()
                                compressed_count += 1
                            else:
                                uncompressed_count += 1
                        elif (
                            len(filename) > 42
                            and filename[38] == "."
                            and filename[-4] == "."
                            and filename[39:-4] in syntaxhighlight.LANGUAGES
                        ):
                            if filename.endswith(".bz2"):
                                if age > max_age_compressed:
                                    self.debug("purging: %s/%s" % (section, filename))
                                    cursor.execute("INSERT INTO purged (sha1) VALUES (%s)", (section + filename[:-4],))
                                    purged_paths.append(fullname)
                                else:
                                    compressed_count += 1
                            elif filename.endswith(".ctx"):
                                self.debug("deleting context file: %s/%s" % (section, filename))
                                os.unlink(fullname)

            self.debug(
                "uncompressed=%d / compressed=%d / purged=%d"
                % (uncompressed_count, compressed_count, len(purged_paths))
            )

            if purged_paths:
                for path in purged_paths:
                    os.unlink(path)
                cursor.execute("DELETE FROM codecontexts USING purged WHERE codecontexts.sha1=purged.sha1")

            db.commit()
            db.close()
开发者ID:mo,项目名称:critic,代码行数:63,代码来源:highlight.py



注:本文中的subprocess.process函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Python subprocess.run函数代码示例发布时间:2022-05-27
下一篇:
Python subprocess.popen函数代码示例发布时间:2022-05-27
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap