那些遇到过的问题

如何在CodeIgniter控制器上运行所有URL所执行的cron作业是从API运行查询,更新数据库并发送电子邮件(从CI内部)？

Ric*_*hez 6 php cron curl codeigniter server

我有一个Web应用程序,它在api上运行查询,获取新信息,更改数据库中的变量并在需要时发送电子邮件(比较旧变量和新变量).

我使用Ubuntu Server,我尝试了几种变体来运行它.

我的控制器看起来像这样:

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...
    }
Run Code Online (Sandbox Code Playgroud)

所以起初我尝试在我的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)
Run Code Online (Sandbox Code Playgroud)

在这上面运行一个快速的谷歌,我注意到我必须在我的服务器上安装"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
Run Code Online (Sandbox Code Playgroud)

仍然,数据库没有任何变化 - 如果有的话 - 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
Run Code Online (Sandbox Code Playgroud)

我真的不知道他们做了什么 - 但仍然无法工作.

编辑:

只是为了清楚,如果我在浏览器上运行控制器,一切都很完美!

这是我在控制器中的所有代码,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'; 
    }


}
Run Code Online (Sandbox Code Playgroud)

编辑#2:

没有is_cli() OR show_404();构造函数时,这很好用.但我确实希望这个控制器只能用于cronjob

我得到了相同的结果:

if (!$this->input->is_cli_request()) show_error('Direct access is not allowed');

Ale*_*lex 5

curl -O - http://10.0.1.666/tools/Cli_only/cron_job >/dev/null 2>&1不是cli。Curl 向您的网络服务器发出正常的 http 请求，同时cli代表 php 命令行脚本。

将其作为 cli 运行：

$ cd /path/to/your/web/root
$ php index.php tools Cli_only cron_job
Run Code Online (Sandbox Code Playgroud)

对于您的工作，它必须是：

14 16 * * *  cd /path/to/project; php tools Cli_only cron_job >/dev/null 2>&1
Run Code Online (Sandbox Code Playgroud)

编辑

curl从 cron 作业运行请求是很常见的做法，它有它的优点。例如，它允许以任何用户身份运行 cron 作业，并保证该作业由网络服务器用户执行。使用 cli，您有责任为正确的用户设置 cron 作业，例如，crontab -u www-data -e如果您的网络服务器用户是www-data. 否则，您有可能弄乱临时文件（如缓存、日志等）的权限。

如果您不确定内部结构，最好curl在您的 cron 作业中继续使用，但限制对某些 IP 地址的控制器的访问。例如代替

is_cli() OR show_404();
Run Code Online (Sandbox Code Playgroud)

使用类似的东西

$this->input->ip_address() == '127.0.0.1' OR show_404();
Run Code Online (Sandbox Code Playgroud)

归档时间：

查看次数：

14541 次

最近记录：

10 年，9 月 前
相关归档
如何检查远程git存储库URL的有效性？ 45
完整安全图像上载脚本 43
单击数据库列时,PHPmyadmin弹出错误通知会一直显示 25
在Laravel 4中向表单添加类/ ID 22
使用cURL登录POST表单 7
Saas：单实例、多实例、单租户、多租户？ 6
curl编译重定向页面列表 1
如何使用Codeigniter减少数据的插入时间？ 1
如何安全地访问外部数据库？ 0
Phoenix / Elixir-cURL有效，但是HTTPoison失败 0
难疑归档
使用CSS更改HTML5输入的占位符颜色 3876
电话和申请有什么区别？ 3012
在JavaScript中循环遍历数组 2940
如何决定何时使用Node.js？ 2198
喜欢构成而不是继承？ 1538
如何在Python中通过索引从列表中删除元素？ 1381
如何正确强制推送Git？ 1206
如何从JavaScript对象中删除密钥？ 1171
在Python中检查类型的规范方法是什么？ 1171
按ID删除元素 1085