我有一个web应用程序，它在api上运行查询，获取新信息，更改数据库中的变量，并在需要时发送电子邮件（比较新旧变量）。
我使用Ubuntu服务器，并尝试了几种变体来运行它。
我的控制器是这样的：
class Cli_only extends CI_Controller {
public function __construct() {
parent::__construct();
is_cli() OR show_404(); // If cronjob !
$this->load->model('kas_model');
// Sets the server not to have a time out.
ini_set('max_execution_time', 0);
ini_set('memory_limit', '-1');
// Expand the array displays
ini_set('xdebug.var_display_max_depth', 5);
ini_set('xdebug.var_display_max_children', 256);
ini_set('xdebug.var_display_max_data', 1024);
}
// This function has to run every day using a corn job.
public function cron_job(){
// does stuff...
}
所以一开始我试着在我的cronjob:上使用常规的"curl"命令
15 15 * * * http://10.0.1.666/tools/Cli_only/cron_job
我在日志文件中得到了这个错误：
Dec 6 15:30:01 MYserver CRON[1134]: (root) CMD (curl http://10.0.1.66/tools/Cli_only/cron_job)
Dec 6 15:30:02 MYserver CRON[1133]: (CRON) info (No MTA installed, discarding output)
在谷歌上快速搜索后，我注意到我必须在服务器上安装"postfix"，我照做了。我重新启动cron并得到：
Dec 6 16:26:01 MYserver cron[2663]: (root) RELOAD (crontabs/root)
Dec 6 16:26:01 MYserver CRON[2703]: (root) CMD (curl http://10.0.1.666/tools/Cli_only/cron_job)
Dec 6 16:26:01 MYserver postfix/pickup[2479]: 23430102E11: uid=0 from=<root>
Dec 6 16:26:01 MYserver postfix/cleanup[2707]: 23430102E11: message-id=<20151206142601.23430102E11@MYserver>
Dec 6 16:26:01 MYserver postfix/qmgr[2480]: 23430102E11: from=<root@MYserver>, size=2058, nrcpt=1 (queue active)
Dec 6 16:26:01 MYserver postfix/local[2709]: 23430102E11: to=<root@MYserver>, orig_to=<root>, relay=local, delay=0.02, delays=0.01/0/0/0, dsn=2.0.0, status=sent (delivered to mailbox)
Dec 6 16:26:01 MYserver postfix/qmgr[2480]: 23430102E11: removed
尽管如此，DB上没有任何变化——如果有的话——CodeIgniter有一个可以工作的邮件配置，只需运行URL就可以工作。
我试着运行这样的东西：
14 16 * * * wget -O - http://10.0.1.666/tools/Cli_only/cron_job >/dev/null 2>&1
14 16 * * * curl -O - http://10.0.1.666/tools/Cli_only/cron_job >/dev/null 2>&1
14 16 * * * GET -O - http://10.0.1.666/tools/Cli_only/cron_job >/dev/null 2>&1
我真的不知道他们在做什么，但仍然不起作用。
编辑：
为了清楚起见，如果我在浏览器上运行控制器，一切都会完美运行！
这是我在控制器中的所有代码，cron_job（）函数就在__construct（）函数之后：
<?php
class Cli_only extends CI_Controller {
public function __construct() {
parent::__construct();
is_cli() OR show_404(); // If cronjob !
//if (!$this->input->is_cli_request()) show_error('Direct access is not allowed');
$this->load->model('kas_model');
// Sets the server not to have a time out.
ini_set('max_execution_time', 0);
ini_set('memory_limit', '-1');
// Expand the array displays
ini_set('xdebug.var_display_max_depth', 5);
ini_set('xdebug.var_display_max_children', 256);
ini_set('xdebug.var_display_max_data', 1024);
}
// This function has to run every day using a corn job.
public function cron_job(){
// 1. Run the query that gets the table data from the DB('from kas table')
$data['table'] = $this->kas_model->get_kas_table();
// 2. Go through each row.
foreach ( $data['table'] as $row ) {
// 3.1. But first, get vars!
$kas_id = $row->kas_id;
$kas_key = $row->kas_key;
$kas_id_aaa = $row->kas_id_aaa;
$kas_id_bbb = $row->kas_id_bbb;
$kas_rank1_aaa = $row->kas_rank1_aaa;
$kas_rank2_aaa = $row->kas_rank2_aaa;
$kas_rank1_bbb = $row->kas_rank1_bbb;
$kas_rank2_bbb = $row->kas_rank2_bbb;
// 3.2. move to yesterday to make place for a new query result.
$this->kas_model->move_tod_to_yes($kas_id, $kas_rank2_aaa, $kas_rank2_bbb);
// 3.3. Run the key query again for today on each one of the keys and insert to DB.
if ( ($kas_id_aaa != 0) || ( !empty($kas_id_aaa) ) ) {
$aaa_rank_today = $this->get_rank_aaa_by_id_and_kw($kas_id_aaa, $kas_key);
}
if ( ($kas_id_bbb != 0) || ( !empty($kas_id_bbb) ) ) {
$bbb_rank_today = $this->get_rank_bbb_by_id_and_kw($kas_id_bbb, $kas_key);
}
// 3.4. Add the new rank to rank2 in the DB.
$this->kas_model->add_new_today($kas_id, $aaa_rank_today, $bbb_rank_today);
// 4. Check difference as Sag described :
$msg = '';
$send = FALSE;
// First if: aaa
if ( ($aaa_rank_today > 10 ) && ( $kas_rank2_aaa < 30 ) && ( ( abs( $aaa_rank_today - $kas_rank2_aaa ) ) > 10) ) {
$msg .= 'aaa:<br> ( (Today > 10 ) && ( Yesterday < 30 ) && ( ( |Today - Yesterday| > 10) ) ==> True. <br><br>';
$send = TRUE;
}
// Second if: aaa
if ( ( ($kas_rank2_aaa < 5) && ($aaa_rank_today > 10) ) || ( ($aaa_rank_today < 5) && ($kas_rank2_aaa > 10) ) ) {
$msg .= 'aaa: <br> ( ( (Yesterday < 5) && (Today > 10) ) || ( (Today < 5) && (Yesterday > 10) ) ) ==> True. <br> <br>';
$send = TRUE;
}
// First if: bbb
if ( ($bbb_rank_today > 10 ) && ( $kas_rank2_bbb < 30 ) && ( ( abs( $bbb_rank_today - $kas_rank2_bbb ) ) > 10) ) {
$msg .= 'bbb: <br> ( (Today > 10 ) && ( Yesterday < 30 ) && ( ( |Today - Yesterday| > 10) ) ==> True. <br><br>';
$send = TRUE;
}
// Second if: bbb
if ( ( ($kas_rank2_bbb < 5) && ($bbb_rank_today > 10) ) || ( ($bbb_rank_today < 5) && ($kas_rank2_bbb > 10) ) ) {
$msg .= 'bbb: <br> ( ( (Yesterday < 5) && (Today > 10) ) || ( (Today < 5) && (Yesterday > 10) ) ) ==> True. <br> <br>';
$send = TRUE;
}
$this->send_mail($kas_id_aaa, $kas_id_bbb, $msg, $send, $aaa_rank_today, $bbb_rank_today, $kas_rank2_aaa, $kas_rank2_bbb, $kas_key);
}
}
// Gets aaa categorys Ranking by ID.
public function get_rank_aaa_by_id_and_kw($id, $key, $query_country){
$key_for_url = rawurlencode($key);
$found = FALSE;
$i = 0;
// Create a stream for Json. That's how the code knows what to expect to get.
$context_opts = array(
'http' => array(
'method' => "GET",
'header' => "Accepts: categorylication/json'r'n"
));
$context = stream_context_create($context_opts);
while ($found == FALSE) {
// aaa Query
$json_query_aaa = "https://api.example.com:666/aaa/ajax/research_key?category_id=$id&term=$key_for_url&page_index=$i&country=$query_country&auth_token=tokentokentoken";
// Get the Json
$json_query_aaa = file_get_contents($json_query_aaa, false, $context);
// Turn Json to a PHP array
$json_query_aaa = json_decode($json_query_aaa, true);
// Finally, the main categorys array.
$json_query_aaa = $json_query_aaa['key']['phone_categorys']['category_list'];
if ( count($json_query_aaa) > 2 ) {
for ( $j=0; $j<count($json_query_aaa); $j++ ) {
if ( $json_query_aaa[$j]['id'] == $id ) {
$found = TRUE;
$rank = $json_query_aaa[$j]['rank'] + 1;
break;
}
if ($found == TRUE){
break;
}
}
$i++;
} else {
$rank = "none";
break;
}
}
return $rank;
}
// Gets bbb categorys Ranking by ID.
public function get_rank_bbb_by_id_and_kw($id, $key, $query_country){
$key_for_url = rawurlencode($key);
$found = FALSE;
$i = 0;
// Create a stream for Json. That's how the code knows what to expect to get.
$context_opts = array(
'http' => array(
'method' => "GET",
'header' => "Accepts: categorylication/json'r'n"
));
$context = stream_context_create($context_opts);
while ($found == FALSE) {
// aaa Query
$json_query_bbb = "https://api.example.com:666/bbb/research_key?category_id=$id&term=$key_for_url&page_index=$i&country=$query_country&auth_token=tokentokentoken";
// Get the Json
$json_query_bbb = file_get_contents($json_query_bbb, false, $context);
// Turn Json to a PHP array
$json_query_bbb = json_decode($json_query_bbb, true);
// Finally, the main categorys array.
$json_query_bbb = $json_query_bbb['key']['phone_categorys']['category_list'];
if ( count($json_query_bbb) > 2 ) {
for ( $j=0; $j<count($json_query_bbb); $j++ ) {
if ( $json_query_bbb[$j]['id'] == $id ) {
$found = TRUE;
$rank = $json_query_bbb[$j]['rank']+1;
}
}
$i++;
} else {
$rank = "none";
break;
}
}
return $rank;
}
// Sends to email the results
public function send_mail($id_aaa, $id_bbb, $msg, $send, $aaa_rank_today, $bbb_rank_today, $aaa_rank_yesterday, $bbb_rank_yesterday, $kas_key){
if ($send) {
$ci = get_instance();
$config['protocol'] = "smtp";
$config['smtp_host'] = "ssl://smtp.gmail.com";
$config['smtp_port'] = "465";
$config['smtp_user'] = "myEmail@example.pro";
$config['smtp_pass'] = "assword";
$config['charset'] = "utf-8";
$config['mailtype'] = "html";
$config['newline'] = "'r'n";
$config['crlf'] = "'r'n";
$config['validate'] = FALSE;
$ci->load->library('email');
$ci->email->initialize($config);
$ci->email->from('myEmail@example.pro', 'key Alerting System (KAS)');
$list = array('myEmail.do@gmail.com', 'sag@example.pro');
$ci->email->to($list);
$this->email->reply_to('no-reply@example.pro', 'KAS Alert');
$ci->email->subject('KAS Alert!');
$ci->email->message("key: $kas_key <br/><br/> aaa ID:$id_aaa <br> bbb ID: $id_bbb <br><br><br> $msg<br><br> aaa Rank Today: $aaa_rank_today<br> aaa Rank Yesterday: $aaa_rank_yesterday<br><br> bbb Rank Today: $bbb_rank_today<br> bbb Rank Yesterday: $bbb_rank_yesterday");
$ci->email->send();
}
}
function test(){
echo 'banana';
}
}
编辑#2：
当构造函数中没有is_cli() OR show_404();时，这一点很好。但我确实希望这个控制器只能在cronjob 上工作
我得到了相同的结果：
if (!$this->input->is_cli_request()) show_error('Direct access is not allowed');
curl -O - http://10.0.1.666/tools/Cli_only/cron_job >/dev/null 2>&1不是cli。Curl向Web服务器发出普通的http请求，而cli代表php命令行脚本。
以cli:运行
$ cd /path/to/your/web/root
$ php index.php tools Cli_only cron_job
对于你的推测，它一定是：
14 16 * * * cd /path/to/project; php tools Cli_only cron_job >/dev/null 2>&1
编辑
从cron作业运行curl请求是非常常见的做法，这有其优点。例如，它允许以任何用户的身份运行cron作业，并保证该作业由Web服务器用户执行。使用cli，您有责任为正确的用户设置cron作业，例如，如果您的Web服务器用户是www-data，则为crontab -u www-data -e。否则，您将面临混淆缓存、日志等临时文件权限的风险。
如果您不确定内部情况，最好在cron作业中继续使用curl，但要限制对特定IP地址的控制器访问。例如，代替
is_cli() OR show_404();
使用类似的东西
$this->input->ip_address() == '127.0.0.1' OR show_404();
首先我不明白为什么要通过http请求运行crotab。你绝对可以在10.0.0.66的服务器上运行crontab，如果互联网出现问题，也可以继续运行。此外，你说"当没有is_cli（）或show_404（）；时，这很好用"，因为在crontab中，您正在编写发送http请求。假设你是客户端，服务器是10.0.0.66。每次运行crontab时，"客户端"都会发送一个http请求。服务器666接收到请求，然后执行您编写的控制器。它不是cli脚本。如果您坚持通过发送http请求来完成此操作。我有两个设备（不是最好的，但可能有效）
- 添加一些只有你知道的GET参数http://10.0.1.666/tools/Cli_only/cron_job?running=no_one_knows_this
- 如果para不是'no_one_knows_this'，请更改控制器以运行para，exit（）
其次，我强烈建议您在服务器上运行bash。