Использование json API pull для хранения в файле или базе данных

Question

Я пытаюсь извлечь данные из API justin.tv и сохранить эхо, полученное в приведенном ниже коде, в базе данных или файле, который будет включен в боковую панель веб-сайта. Я не уверен, как это сделать. Примером того, чего я пытаюсь достичь, является список живых стримеров на боковой панели teamliquid.net. Что я и сделал, но сделал так, как сделал, это замедляет работу сайта, потому что он выполняет около 50 запросов json при каждой загрузке страницы. Мне просто нужно поместить это в кэшированный файл, который обновляется каждые 60 секунд или около того. Есть идеи?

<?php
$json_file = file_get_contents("http://api.justin.tv/api/stream/list.json?channel=colcatz");
$json_array = json_decode($json_file, true);

if ($json_array[0]['name'] == 'live_user_colcatz') echo '<a href="http://www.twitch.tv/colcatz">coL.CatZ</a> Live<br>';

$json_file = file_get_contents("http://api.justin.tv/api/stream/list.json?channel=coldrewbie");
$json_array = json_decode($json_file, true);

if ($json_array[0]['name'] == 'live_user_coldrewbie') echo '<a href="http://www.twitch.tv/coldrewbie">coL.drewbie</a> Live<br>';
?>

Answer 1

Я не совсем уверен, как вы представите, что это кэшируется, но приведенный ниже код представляет собой адаптацию блока кода, который я использовал в прошлом для работы в Twitter. Есть несколько вещей, которые можно было бы сделать лучше с точки зрения безопасности. В любом случае, это дает вам общий способ захвата Лента, его анализа и последующей отправки в базу данных.

Предупреждение. Предполагается, что в вашей системе уже установлено соединение с базой данных.

(* Убедитесь, что вы прокручиваете до конца окна кода *)

/**
 * Class SM
 *
 * Define a generic wrapper class with some system
 * wide functionality. In this case we'll give it
 * the ability to fetch a social media feed from
 * another server for parsing and possibly caching.
 *
 */

class SM {

  private $api, $init, $url;

  public function fetch_page_contents ($url) {

    $init = curl_init();

    try {
      curl_setopt($init, CURLOPT_URL, $url);
      curl_setopt($init, CURLOPT_HEADER, 0);      
      curl_setopt($init, CURLOPT_RETURNTRANSFER, 1);      
    } catch (Exception $e) {
      error_log($e->getMessage());
    }

    $output = curl_exec($init);
    curl_close($init);

    return $output;
  }

}


/**
 * Class JustinTV
 *
 * Define a specific site wrapper for getting the
 * timeline for a specific user from the JustinTV
 * website. Optionally you can return the code as
 * a JSON string or as a decoded PHP array with the
 * $api_decode argument in the get_timeline function.
 *
 */
class JustinTV extends SM {

  private $timeline_document,
          $api_user,
          $api_format,
          $api_url;

  public function get_timeline ($api_user, $api_decode = 1, $api_format = 'json', $api_url = 'http://api.justin.tv/api/stream/list') {

    $timeline_document = $api_url . '.' . $api_format . '?channel=' . $api_user;

    $SM_init = new SM();

    $decoded_json = json_decode($SM_init->fetch_page_contents($timeline_document));

    // Make sure that our JSON is really JSON
    if ($decoded_json === null && json_last_error() !== JSON_ERROR_NONE) {
      error_log('Badly formed, dangerous, or altered JSON string detected. Exiting program.');
    }

    if ($api_decode == 1) {
      return $decoded_json;
    }

    return $SM_init->fetch_page_contents($timeline_document);   
  }

}


/**
 * Instantiation of the class
 *
 * Instantiate our JustinTV class, fetch a user timeline
 * from JustinTV for the user colcatz. The loop through
 * the results and enter each of the individual results
 * into a database table called cache_sm_justintv.
 *
 */
$SM_JustinTV = new JustinTV();

$user_timeline = $SM_JustinTV->get_timeline('colcatz');

foreach ($user_timeline AS $entry) {

  // Here you could check whether the entry already exists in the system before you cache it, thus reducing duplicate ID's

  $date = date('U');

  $query = sprintf("INSERT INTO `cache_sm_justintv` (`id`, `cache_content`, `date`) VALUES (%d, '%s', )", $entry->id, $entry, $date);
  $result = mysql_query($query);

  // Do some other stuff and then close the MySQL Connection when your done

}