jobmatch query

client = pymongo.MongoClient("mongodb+srv://test:<password>@cluster0.nq0me.mongodb.net/<dbname>?retryWrites=true&w=majority")

def query(country,keywords):

    result = client['database1']['collection1'].aggregate([
        {
            '$search': {
                'text': {
                    'path': [
                        'industry'
                    ], 
                    'query': [
                        ' %s' % (keywords)
                    ], 
                    'fuzzy': {
                        'maxEdits': 2, 
                        'prefixLength': 2
                    }
                }
            }
        }, {
            '$project': {
                'Name': '$name', 
                'URL': '$domain', 
                'Industry': '$industry', 
                'University': '$Uni', 
                'City': '$locality', 
                'Country': '$country', 
                'score': {
                    '$meta': 'searchScore'
                }
            }
        }, {
            '$match': {
                'Country': '%s' % (country)
            }
        }, {
            '$limit': 10
        }
    ])

    df = pd.DataFrame(result)

    return df