A Symfony integration of Mineur Twitter Stream Library.
composer require mineur/twitter-stream-api-bundle:dev-masterRegister this bundle into your application kernel.
// app/AppKernel.php class AppKernel extends Kernel { public function registerBundles() { $bundles = [ // ... new Mineur\TwitterStreamApiBundle\TwitterStreamApiBundle(), ]; } }Then add your authentication keys on your config file:
# app/config/config.yml twitter_stream_api: twitter: consumer_key: '%your_consumer_key%' consumer_secret: '%your_consumer_secret%' access_token: '%your_access_token%' access_token_secret: '%your_access_token_secret%'// Controllers/DemoController.php class DemoCommand extends ContainerAwareCommand { protected function configure() { //... } public function execute(InputInterface $input, OutputInterface $output) { /** @var PublicStream $publicStream */ $publicStream = $this ->getContainer() ->get('twitter_stream_api_consumer'); $publicStream ->listenFor([ 'your', 'keywords', 'list' ]) ->setLanguage('es') ->do(function(Tweet $tweet) { // you can do whatever you want with this output // prompt it, enqueue it, persist it into a database ... $output->writeln($tweet); }); } }Check out the library for full customization of the public stream: twitter-stream-api
Tu use the pre-configured commands:
- To prompt the stream feed on your terminal:
bin/console mineur:twitter-stream:consume hello,hola,aloha- To enqueue the stream output as a serialized objects in a FIFO Redis queue, type the following:
This part is subject to RSQueue library and RSQueueBundle. I recommend you to check the RSQueue documentation to consume the enqueued objects.
bin/console mineur:twitter-stream:enqueueConsuming the stream will give you an infinite loop of hydrated Tweet objects, similar to this one:
Mineur\TwitterStreamApi\Tweet {#424 -text: "Hello twitter!" -lang: "en" -createdAt: "Thu May 25 18:48:05 +0000 2017" -timestampMs: "1495738085984" -geo: array:12 [ // ... ] -coordinates: array:14 [ // ... ] -places: null -retweetCount: 236 -favoriteCount: 52 -user: array:38 [ "id" => 2605080321 // ... ] }