mrtj

#!/usr/bin/env python3

import boto3
import requests
import tqdm
from urllib.parse import urlparse

def stream_to_s3(
    source_url,
    target_url,

mrtj

import gi

gi.require_version('Gst', '1.0')
gi.require_version('GstRtspServer', '1.0')
from gi.repository import GLib, Gst, GstRtspServer

Gst.init(None)

import argparse
parser = argparse.ArgumentParser(description='GStreamer RTSP server test-launch')

mrtj

'''
A snippet demonstrating how an AWS IoT device can make direct calls to every AWS
service using only the device certificate and private key.

For more info see the docs at https://docs.aws.amazon.com/iot/latest/developerguide/authorizing-direct-aws.html
to create the role and the role alias. To get the AWS IoT credential provider endpoint of your account you can use

    $ aws iot describe-endpoint --endpoint-type iot:CredentialProvider
    
Dependencies: requests and boto3

mrtj

import panoramasdk
from backpack.annotation import (
    Point, LabelAnnotation, RectAnnotation, TimestampAnnotation,
    OpenCVImageAnnotationDriver, 
    PanoramaMediaAnnotationDriver
)

class Application(panoramasdk.node):

    def __init__(self):

mrtj

import panoramasdk
from backpack.kvs import KVSSkyLine, KVSFileCredentialsHandler

# You might want to read these values from Panorama application parameters
stream_region = 'us-east-1'
stream_name = 'panorama-video'

# The example Dockerfile writes static configuration variables to this file
# If you change the .env file path in the Dockerfile, you should change it also here
DOTENV_PATH = '/panorama/.env'

mrtj

import functools

def lazy_property(func):
    ''' Caches the return value of a function, and turns it into a property. 
    
    Intended to be used as a function decorator::
    
        >>> class Foo:
        >>>     @lazy_property
        >>>     def bar(self):

mrtj

''' The parse_telegram_export function in this gist parses the html export of a Telegram chat.
You should have [BeautifulSoup](https://www.crummy.com/software/BeautifulSoup/bs4/) and 
[dateutil](https://dateutil.readthedocs.io/) installed. It extracts the sender name, the 
message date and time, the message text and the links in the message.
'''

from bs4 import BeautifulSoup
import dateutil

def parse_telegram_export(html_str, tz_name=None):

mrtj

import os
import json
from pathlib import Path
from urllib.parse import urljoin

import jsonschema

def add_local_schemas_to(resolver, schema_folder, base_uri, schema_ext='.schema.json'):
    ''' Add local schema instances to a resolver schema cache. 
    

mrtj

mrtj

class Application(panoramasdk.node):
    
    # ...
    
    def process_media(self, stream):
        image_data, ratio = self.preprocess(stream.image, self.MODEL_INPUT_SIZE)
        inference_results = self.call(
            {self.MODEL_INPUT_NAME: image_data}, self.MODEL_NODE
        )
        self.process_results(inference_results, stream, ratio)