Crontab 上的 Python 不执行 bash 脚本

Question

import subprocess as sub
import re
import os
from datetime import datetime as influx_timestap
from influxdb import InfluxDBClient
from collections import OrderedDict

insert_json = []
hostname = str(sub.check_output('hostname')).strip()
location = str(sub.check_output(['ps -ef | grep mgr'], shell=True)).split()
current_dir = os.getcwd()
print("script executed")
gg_location_pattern = re.compile(r'mgr\.prm$')
gg_process_pattertn = re.compile(r'^REPLICAT|^EXTRACT')
for index in location:
    if gg_location_pattern.search(index) != None:
        gg_location = index[:-14]

os.chdir(gg_location)
print("checkpoint1")
get_lag = sub.check_output(str(current_dir) + '/ggsci_test.sh', shell=True)
print("checkpoint2")
processes = get_lag.split("\n")

for process in processes:
    if gg_process_pattertn.search(process) != None:
        lag_at_chkpnt = int((process.split()[3]).split(":")[0]) * 3600 + int((process.split()[3]).split(":")[1]) *60 + int((process.split()[3]).split(":")[2])
        time_since_chkpnt = int((process.split()[4]).split(":")[0]) * 3600 + int((process.split()[4]).split(":")[1]) *60 + int((process.split()[4]).split(":")[2]
)
        process_dict = OrderedDict({"measurement": "GoldenGate_Mon_" + str(hostname) +  "_Graph",
                        "tags": {"hostname": hostname, "process_name": process.split()[2]},
                        "time": influx_timestap.now().isoformat('T'),
                        "fields": {"process_type": process.split()[0], "process_status": process.split()[1],
                        "lag_at_chkpnt": lag_at_chkpnt, "time_since_chkpnt": time_since_chkpnt}})
        insert_json.append(process_dict)


host = 'xxxxxxxx'
port = 'x'
user = 'x'
password = 'x'
dbname = 'x'
print("before client")
client = InfluxDBClient(host, port, user, password, dbname)
client.write_points(insert_json)
print("after client")

此代码手动完美运行，但在 crontab 上无法正常工作。在互联网上搜索后，我发现他们说在 crontab 上更改或设置您的“PATH”变量。我更改了我的“PATH”变量，但它仍然无法正常工作。

Crontab 日志文件写入“checkpoint1”之后就什么都没有了。所以，线路不工作是"get_lag = sub.check_output(str(current_dir) + '/ggsci_test.sh', shell=True)"

之后我可以在这里做什么？ 保重，

Answer 1

您的外部脚本 (ggsci_test.sh) 似乎在路径/一般故障方面存在一些问题。

来自Python subprocess documentation关于subprocess.check_output：

如果返回码不为零，则会引发 CalledProcessError。这 CalledProcessError 对象将在 returncode 中有返回码 属性和输出属性中的任何输出。

这就是为什么您在捕获错误时看到错误但无法继续的原因。

因此，您应该检查您的 shell 脚本之前是否有任何需要解决的问题。