我有一个自定义的python插件，我正在使用它将数据拉入Telegraf。它按预期打印出线路协议输出。
在我的Ubuntu 18.04环境中，当这个插件运行时，我在日志中看到一行：
2020-12-28T21:55:00Z E! [inputs.exec] Error in plugin: exec: exit status 1 for command '/my_company/plugins-enabled/plugin-mysystem/poll_mysystem.py': Traceback (most recent call last):...
就是这样。我不知道如何得到实际的回溯。
如果我运行sudo -u telegraf /usr/bin/telegraf -config /etc/telegraf/telegraf.conf，插件将按预期工作。它按照应该的方式轮询和加载数据。
当telegrap自己执行插件时，我不知道如何解决这个错误。
我已重新启动电报服务。我已经验证了权限(我认为上面的执行表明它应该可以工作(。
基于收到的评论和答案的一些额外细节：
- 插件位于整个结构归
telegraf:telegraf所有的目录中。这个错误似乎并不意味着它看不到正在执行的文件，而是Telegraf执行插件时文件中的某些东西出现了故障 - 插头的代码如下
插件代码(/my_company/plugins-enabled/plugin-mysystem/poll_mysystem.py(：
from google.auth.transport.requests import Request
from google.oauth2 import id_token
import requests
import os
RUNTIME_URL = INTERNAL_URL
MEASUREMENT = "MY_MEASUREMENT"
CREDENTIALS = "GOOGLE_SERVICE_FILE.json"
os.environ["GOOGLE_APPLICATION_CREDENTIALS"] = CREDENTIALS # ENV VAR REQUIRED BY GOOGLE CODE BELOW
CLIENT_ID = VALUE_FROM_GOOGLE
exclude_fields = ["name", "version"] # Don't try to put these into influxdb from json response
def make_iap_request(url, client_id, method="GET", **kwargs):
# Code provided by Google docs
# Set the default timeout, if missing
if "timeout" not in kwargs:
kwargs["timeout"] = 90
# Obtain an OpenID Connect (OIDC) token from metadata server or using service
# account.
open_id_connect_token = id_token.fetch_id_token(Request(), client_id)
# Fetch the Identity-Aware Proxy-protected URL, including an
# Authorization header containing "Bearer " followed by a
# Google-issued OpenID Connect token for the service account.
resp = requests.request(method, url, headers={"Authorization": "Bearer {}".format(open_id_connect_token)}, **kwargs)
if resp.status_code == 403:
raise Exception("Service account does not have permission to " "access the IAP-protected application.")
elif resp.status_code != 200:
raise Exception(
"Bad response from application: {!r} / {!r} / {!r}".format(resp.status_code, resp.headers, resp.text)
)
else:
return resp.json()
def print_results(results):
"""
Take the results of a Dolores call and print influx line protocol results
"""
for item in results["workflow"]:
line_protocol_line_base = f"{MEASUREMENT},name={item['name']}"
values = ""
for key, value in item.items():
if key not in exclude_fields:
values = values + f",{key}={value}"
values = values[1:]
line_protocol_line = f"{line_protocol_line_base} {values}"
print(line_protocol_line)
def main():
current_runtime = make_iap_request(URL, CLIENT_ID, timeout=30)
print_results(current_runtime)
if __name__== "__main__":
main()
telegraf.conf文件的相关部分：
[[inputs.exec]]
## Commands array
commands = [
"/my_company/plugins-enabled/plugin-*/poll_*.py",
]
配置文件的代理部分
[agent]
interval = "60s"
round_interval = true
metric_batch_size = 1000
metric_buffer_limit = 10000
collection_jitter = "0s"
flush_interval = "10s"
flush_jitter = "0s"
precision = ""
debug = false
quiet = false
logfile = "/var/log/telegraf/telegraf.log"
hostname = ""
omit_hostname = true
我下一步该怎么办？
exec插件正在换行处截断您的Exception消息。如果您将对make_iap_request的调用封装在try/except块中，然后将print(e, file=sys.stderr)封装起来，而不是让Exception一直冒泡，这应该会告诉您更多信息。
def main():
"""
Query URL and print line protocol
"""
try:
current_runtime = make_iap_request(URL, CLIENT_ID, timeout=30)
print_results(current_runtime)
except Exception as e:
print(e, file=sys.stderr)
或者，您的脚本可以将错误消息记录到自己的日志文件中，而不是将它们传回Telegraf。这将使您能够更好地控制所记录的内容。
我怀疑你遇到了环境问题，你运行它的方式有所不同。如果不是权限，可能是环境变量的差异。
请检查权限。这似乎是一个权限错误。由于Telegraph拥有运行sudo -u telegraf工作所必需的权限。但是您尝试使用的user没有访问/my_company/plugins-enabled/中的文件所需的权限。
因此，我建议查看它们，并将权限更改为Other can access and write或您试图使用Telegram的用户名。
为了解决这个问题，运行命令转到目录：
cd/my_company/plugins enabled/
然后将所有权更改为您且仅限于您：
sudo chown-R$(whoami(
然后更改所有文件和文件夹的读/写权限，否则：
sudo chmod-R u+w
如果你想让系统上的所有人，实际上是每个人都有权读/写这些文件和文件夹，只想给每个人所有权限：
sudo chmod-R 777