hunterist
commented
8 years ago <?php
$config = null;
$clientConfig = null;
/* @var $clientConfig KalturaConfiguration */
$client = null;
/* @var $client KalturaClient */
require_once __DIR__ . '/init.php';
$logrotate = $config['dwh']['logRotateBin'];
$kitchen_script= $config['dwh']['kitchenScript'];
$appDir = $config['global']['appDir'];
$dwhDir = $config['dwh']['baseDir'];
$kalturaUser = $config['os']['kalturaUser'];
/**
* Start a new session
*/
$partnerId = $config['session']['partnerId'];
$adminSecretForSigning = $config['session']['adminSecret'];
//echo $partnerId . " and " . $adminSecretForSigning; die();
$client->setKs($client->generateSessionV2($adminSecretForSigning, 'sanity-user', KalturaSessionType::ADMIN, $partnerId, 86400, ''));
//echo $client->generateSessionV2($adminSecretForSigning, 'sanity-user', KalturaSessionType::ADMIN, $partnerId, 86400, '');
/**
* List players
*/
$playersFilter = new KalturaUiConfFilter();
$playersFilter->objTypeIn = KalturaUiConfObjType::PLAYER_V3 . ',' . KalturaUiConfObjType::PLAYER;
$playersFilter->orderBy = KalturaUiConfOrderBy::CREATED_AT_DESC;
$playersPager = new KalturaFilterPager();
$playersPager->pageSize = 1;
$playersList = $client->uiConf->listAction($playersFilter, $playersPager);
/* @var $playersList KalturaUiConfListResponse */
if(!$playersList || !$playersList->totalCount || !count($playersList->objects))
{
echo "No player found\n";
exit(-1);
}
$player = reset($playersList->objects);
/**
* List ready media entries
*/
$entriesFilter = new KalturaMediaEntryFilter();
$entriesFilter->mediaTypeEqual = KalturaMediaType::VIDEO;
$entriesFilter->statusEqual = KalturaEntryStatus::READY;
$entriesFilter->orderBy = KalturaMediaEntryOrderBy::DURATION_ASC;
$entriesFilter->partnerId=$partnerId;
$entriesPager = new KalturaFilterPager();
$entriesPager->pageSize = 1;
$entriesList = $client->media->listAction($entriesFilter, $entriesPager);
/* @var $entriesList KalturaMediaListResponse */
if(!$entriesList || !$entriesList->totalCount || !count($entriesList->objects))
{
echo "No ready media entry found\n";
exit(-1);
}
$entry = reset($entriesList->objects);
/* @var $entry KalturaMediaEntry */
/**
* Calls stats.collect
*
* TODO:
* - Run it once on each API server.
*/
$client->getConfig()->method = KalturaClientBase::METHOD_GET;
$event = new KalturaStatsEvent();
$event->isFirstInSession = false;
$event->seek = false;
$event->clientVer = '3.0:v3.7';
$event->referrer = $clientConfig->serviceUrl . 'sanity/tests';
$event->sessionId = uniqid('SANITY-TEST-');
$event->entryId = $entry->id;
$event->partnerId = $entry->partnerId;
$event->duration = $entry->duration;
$event->currentPoint = 0;
$event->uiconfId = $player->id;
$event->eventType = KalturaStatsEventType::WIDGET_LOADED;
$event->eventTimestamp = microtime(true);
try
{
$client->stats->collect($event);
}
catch (KalturaClientException $e){}
echo "Sent event [KalturaStatsEventType::WIDGET_LOADED]\n";
$event->eventType = KalturaStatsEventType::MEDIA_LOADED;
$event->eventTimestamp = microtime(true);
try
{
$client->stats->collect($event);
}
catch (KalturaClientException $e){}
echo "Sent event [KalturaStatsEventType::MEDIA_LOADED]\n";
$event->eventType = KalturaStatsEventType::PLAY;
$event->eventTimestamp = microtime(true);
//$s = unserialize($event);
//var_dump($event);die();
$client->stats->collect($event);
try
{
//$client->stats->collect($event);
//var_dump($client);die();
}
catch (KalturaClientException $e){
//var_dump($event);
//echo $e->getMessage();die();
}
echo "Sent event [KalturaStatsEventType::PLAY]\n";
$quarter = ceil(($entry->msDuration / 4) * 1000);
usleep($quarter);
$event->currentPoint += $quarter;
$event->eventType = KalturaStatsEventType::PLAY_REACHED_25;
$event->eventTimestamp = microtime(true);
try
{
$client->stats->collect($event);
}
catch (KalturaClientException $e){
echo "Can not count play_reached_25\n";
}
echo "Sent event [KalturaStatsEventType::PLAY_REACHED_25]\n";
usleep($quarter);
$event->currentPoint += $quarter;
$event->eventType = KalturaStatsEventType::PLAY_REACHED_50;
$event->eventTimestamp = microtime(true);
try
{
$client->stats->collect($event);
}
catch (KalturaClientException $e){}
echo "Sent event [KalturaStatsEventType::PLAY_REACHED_50]\n";
usleep($quarter);
$event->currentPoint += $quarter;
$event->eventType = KalturaStatsEventType::PLAY_REACHED_75;
$event->eventTimestamp = microtime(true);
try
{
$client->stats->collect($event);
}
catch (KalturaClientException $e){}
echo "Sent event [KalturaStatsEventType::PLAY_REACHED_75]\n";
usleep($quarter);
$event->currentPoint = $entry->msDuration;
$event->eventType = KalturaStatsEventType::PLAY_REACHED_100;
$event->eventTimestamp = microtime(true);
try
{
$client->stats->collect($event);
}
catch (KalturaClientException $e){}
echo "Sent event [KalturaStatsEventType::PLAY_REACHED_100]\n";
$client->getConfig()->method = KalturaClientBase::METHOD_POST;
/**
* Rotate logs.
*/
$returnedValue = null;
$cmd = "$logrotate -f /etc/logrotate.d/kaltura_apache";
echo "Executing [$cmd]";
passthru($cmd, $returnedValue);
if($returnedValue !== 0)
{
// echo " failed\n";
// exit(-1);
}
echo " log rotated\n";
/**
* Run hourly scripts.
*/
$cmd = "su $kalturaUser -c '$dwhDir/etlsource/execute/etl_hourly.sh -p $dwhDir -k $kitchen_script '";
echo "Executing [$cmd]";
passthru($cmd, $returnedValue);
if($returnedValue !== 0)
{
echo " failed\n";
exit(-1);
}
echo " OK\n";
/**
* Run update dimensions.
*/
$cmd = "su $kalturaUser -c '$dwhDir/etlsource/execute/etl_update_dims.sh -p $dwhDir -k $kitchen_script'";
echo "Executing [$cmd]";
passthru($cmd, $returnedValue);
//if($returnedValue !== 0)
//{
// echo " failed [$cmd]\n";
// exit(-1);
//}
echo " OK\n";
/**
* Run daily scripts.
*/
$cmd = "su $kalturaUser -c '$dwhDir/etlsource/execute/etl_daily.sh -p $dwhDir -k $kitchen_script'";
echo "Executing [$cmd]";
passthru($cmd, $returnedValue);
if($returnedValue !== 0)
{
echo " failed [$cmd]\n";
exit(-1);
}
echo " OK\n";
/**
* Validate the results using the API
*
* TODO:
* - Validate that the data collected from all API machines.
*/
$dateTimeZoneServer = new DateTimeZone(date_default_timezone_get());
$dateTimeZoneUTC = new DateTimeZone("UTC");
$dateTimeUTC = new DateTime("now", $dateTimeZoneUTC);
$timeOffsetSeconds = $dateTimeZoneServer->getOffset($dateTimeUTC);
$reportInputFilter = new KalturaReportInputFilter();
$reportInputFilter->timeZoneOffset = ($timeOffsetSeconds / -60);
$reportInputFilter->fromDay = date('Ymd', time() - (60 * 60 * 24));
$reportInputFilter->toDay = date('Ymd');
$reportInputPager = new KalturaFilterPager();
$reportTable = $client->report->getTable(KalturaReportType::TOP_CONTENT, $reportInputFilter, $reportInputPager, null, $entry->id);
/* @var $reportTable KalturaReportTable */
if($reportTable->totalCount != 1)
{
//print_r($reportTable);
echo "Reported wrong total count [$reportTable->totalCount]\n";
exit(-1);
}
$titles = explode(',', $reportTable->header);
$data = explode(';', $reportTable->data);
if(!$reportTable->data || count($data) != 2)
{
echo "Reported wrong data count\n";
exit(-1);
}
$recordData = explode(',', reset($data));
$record = array_combine($titles, $recordData);
if($record['object_id'] != $entry->id)
{
echo "Reported data of wrong entry [" . $record['object_id'] . "]\n";
exit(-1);
}
if(!isset($record['count_plays']) || !$record['count_plays'] || !intval($record['count_plays']))
{
echo "Reported wrong plays count [" . $record['count_plays'] . "]\n";
exit(-1);
}
if(!isset($record['count_loads']) || !$record['count_loads'] || !intval($record['count_loads']))
{
echo "Reported wrong loads count [" . $record['count_loads'] . "]\n";
exit(-1);
}
$expectedTimeViewed = round($entry->duration / 60, 2);
if(!isset($record['sum_time_viewed']) || !$record['sum_time_viewed'] || floatval($record['sum_time_viewed']) < $expectedTimeViewed)
{
echo "Reported wrong view time [" . $record['sum_time_viewed'] . "] expected at least [$expectedTimeViewed]\n";
exit(-1);
}
echo "Reports OK\n";
/**
* Syncyng plays and view from the dwh to the operational db
*/
$cmd = "su $kalturaUser -c $appDir/alpha/scripts/dwh/dwh_plays_views_sync.sh >/tmp/dwh_plays_views_sync.log";
echo "Executing [$cmd]";
passthru($cmd, $returnedValue);
if($returnedValue !== 0)
{
echo " failed [$cmd]\n";
exit(-1);
}
echo " OK\n";
/**
* Reload the entry and check plays and views
*/
$reloadedEntry = $client->media->get($entry->id);
/* @var $reloadedEntry KalturaMediaEntry
*/
if($reloadedEntry->plays <= $entry->plays)
{
echo "Entry [$entry->id] plays [$reloadedEntry->plays] did not incremented\n";
exit(-1);
}
if($reloadedEntry->views <= $entry->views)
{
echo "Entry [$entry->id] views [$reloadedEntry->views] did not incremented\n";
exit(-1);
}
echo "Plays and views OK - $entry->id\n";
kaltura-hooks
When I run:
php /opt/kaltura/bin/dwh_cycle.php /opt/kaltura/bin/sanity_config.iniThe result
I dont use try-catch with $client->stats->collect($event) function in /opt/kaltura/bin/dwh_cycle.php
Please help check. Thank you so much.